Reactive Core


Reactor is a fully non-blocking foundation with efficient demand management. It directly interacts with Java 8 functional API, Completable Future, Stream and Duration.

Typed [0|1|N] Sequences


Reactor offers 2 reactive composable API Flux [N] and Mono [0|1] extensively implementing Reactive Extensions. It also supports scalable in-memory routing with Bus extensions.

Non blocking IPC


Suited for Microservices Architecture, Reactor IPC offers backpressure-ready network engines for HTTP (including Websockets), TCP and UDP. Reactive Encoding/Decoding is fully supported.

Efficient Message Passing

Reactor Processors, Operators and Timers can sustain high throughput rates on the order of 10's of millions of messages per second. Plus its low memory footprint should go under most of the radars. Reactor is part of an ongoing research effort to challenge further the possible flow optimizations.

Friendly Adoption

As a Reactive Engine/SPI, both Reactor Core and IO modules expose reactive streams constructs for focused use cases, eventually combined with Spring, RxJava, Akka Streams, Ratpack... As a Reactive API, reactor framework modules will offer rich consumable features like composition and pub-sub eventing.

Guardian of the Latency

Scaling-Out to overcome latency and slow microservices is an important tool. Cloud Native apps will have a better chance at effective scale-out with asychronous architectures. To assist such design, Reactor offers non-blocking and backpressure-ready embeddable solutions including local and remote Unicast/Multicast messaging or TCP/HTTP/UDP client & servers.

Reactor is Powering

Clojure Werkz Codecentric EMC2 Spring Doc4web Pivotal Vodafone Grails OpenSensors Instana Redisson