reactor.core.spec

Class Reactors

java.lang.Object

reactor.core.spec.Reactors

public abstract class Reactors
extends java.lang.Object

Base class to encapsulate commonly-used functionality around Reactors.

Constructor Summary

Constructors

Constructor and Description
Reactors()

Method Summary

Modifier and Type	Method and Description
static ReactorSpec	reactor() Create a new ReactorSpec to configure a Reactor.
static Reactor	reactor(Environment env) Create a new Reactor using the given Environment.
static Reactor	reactor(Environment env, Dispatcher dispatcher) Create a new Reactor using the given Environment and Dispatcher.
static Reactor	reactor(Environment env, java.lang.String dispatcher) Create a new Reactor using the given Environment and dispatcher name.
static <T> void	schedule(Consumer<T> consumer, T data, Observable observable) Deprecated. @since 1.1

Methods inherited from class java.lang.Object

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

Constructor Detail

Reactors

public Reactors()

Method Detail

reactor

public static ReactorSpec reactor()

Create a new ReactorSpec to configure a Reactor.

Returns:

The Reactor spec

reactor

public static Reactor reactor(Environment env)

Create a new Reactor using the given Environment.

Parameters:

env - The Environment to use.

Returns:

A new Reactor

reactor

public static Reactor reactor(Environment env,
                              java.lang.String dispatcher)

Create a new Reactor using the given Environment and dispatcher name.

Parameters:

env - The Environment to use.

dispatcher - The name of the Dispatcher to use.

Returns:

A new Reactor

reactor

public static Reactor reactor(Environment env,
                              Dispatcher dispatcher)

Create a new Reactor using the given Environment and Dispatcher.

Parameters:

env - The Environment to use.

dispatcher - The Dispatcher to use.

Returns:

A new Reactor

schedule

@Deprecated
public static <T> void schedule(Consumer<T> consumer,
                                            T data,
                                            Observable observable)

Deprecated. @since 1.1

Schedule an arbitrary Consumer to be executed on the given Observable, passing the given Event.

Type Parameters:

T - The type of the data.

Parameters:

consumer - The Consumer to invoke.

data - The data to pass to the consumer.

observable - The Observable that will be used to invoke the Consumer