org.jooby.reactor

Class Reactor

java.lang.Object

org.jooby.reactor.Reactor

All Implemented Interfaces:

org.jooby.Jooby.Module

public class Reactor
extends Object
implements org.jooby.Jooby.Module

reactor

Reactor is a second-generation Reactive library for building non-blocking applications on the JVM based on the Reactive Streams Specification

exports

• map route operator that converts Flux and Mono into Deferred API.

usage

 ...
 import org.jooby.reactor.Reactor;
 ...

 {
   use(new Reactor());

   get("/", req -> Flux.just("reactive programming in jooby!"));
 }
 

how it works?

Previous example is translated to:

 {
   use(new Reactor());

   get("/", req -> {

    return new Deferred(deferred -> {
      Flux.just("reactive programming in jooby!")
        .consume(deferred::resolve, deferred::reject);
    });

   });
 }
 

Translation is done via reactor() route mapper. If you are a reactor programmer then you don't need to worry for learning a new API and semantic. The reactor() route operator deal and take cares of the Deferred API.

reactor mapper

Advanced flux/mono configuration is allowed via function adapters:

 ...
 import org.jooby.reactor.Reactor;
 ...

 {
   use(new Reactor()
       .withFlux(f -> f.publishOn(Computations.concurrent())
       .withMono(m -> m.publishOn(Computations.concurrent()));

   get("/flux", req -> Flux...);

   get("/mono", req -> Mono...);

 }
 

Here every Flux/Mono from a route handler will publish on the concurrent scheduler.

Since:

1.0.0.CR3

Author:

edgar

Constructor Summary

Constructors

Constructor and Description
Reactor()

Method Summary

Modifier and Type	Method and Description
void	configure(org.jooby.Env env, com.typesafe.config.Config conf, com.google.inject.Binder binder)
static org.jooby.Route.Mapper<Object>	reactor() Map a reactor object like Flux or Mono into a Deferred object.
static org.jooby.Route.Mapper<Object>	reactor(Function<reactor.core.publisher.Flux,reactor.core.publisher.Flux> flux, Function<reactor.core.publisher.Mono,reactor.core.publisher.Mono> mono) Map a reactor object like Flux or Mono into a Deferred object.
Reactor	withFlux(Function<reactor.core.publisher.Flux,reactor.core.publisher.Flux> adapter)
Reactor	withMono(Function<reactor.core.publisher.Mono,reactor.core.publisher.Mono> adapter)

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.jooby.Jooby.Module

config

Constructor Detail

Reactor

public Reactor()

Method Detail

withFlux

public Reactor withFlux(Function<reactor.core.publisher.Flux,reactor.core.publisher.Flux> adapter)

withMono

public Reactor withMono(Function<reactor.core.publisher.Mono,reactor.core.publisher.Mono> adapter)

reactor

public static org.jooby.Route.Mapper<Object> reactor(Function<reactor.core.publisher.Flux,reactor.core.publisher.Flux> flux,
                                                     Function<reactor.core.publisher.Mono,reactor.core.publisher.Mono> mono)

Map a reactor object like Flux or Mono into a Deferred object.

 ...
 import org.jooby.reactor.Reactor;
 ...

 {
   with(() -> {
     get("/lux", req -> Flux...);

     get("/mono", req -> Mono...);

   }).map(Reactor.reactor(
       flux -> flux.publishOn(Computations.concurrent()),
       mono -> mono.publishOn(Computations.concurrent()));
 }
 

Parameters:

flux - A flux adapter.

mono - A mono adapter.

Returns:

A new mapper.

reactor

public static org.jooby.Route.Mapper<Object> reactor()

Map a reactor object like Flux or Mono into a Deferred object.

 ...
 import org.jooby.reactor.Reactor;
 ...

 {
   with(() -> {
     get("/lux", req -> Flux...);

     get("/mono", req -> Mono...);

   }).map(Reactor.reactor(
       flux -> flux.publishOn(Computations.concurrent()),
       mono -> mono.publishOn(Computations.concurrent()));
 }
 

Returns:

A new mapper.

configure

public void configure(org.jooby.Env env,
                      com.typesafe.config.Config conf,
                      com.google.inject.Binder binder)

Specified by:

configure in interface org.jooby.Jooby.Module