com.aol.micro.server.javaslang.reactive

Interface JavaslangReactive

public interface JavaslangReactive

Mixin / Trait for Reactive behaviour via simple-react

Method Summary

Modifier and Type	Method and Description
default <K,T> com.aol.simple.react.stream.traits.LazyFutureStream<T>	cpuFutureStream(K key) Get a LazyFutureStream optimized for CPU operations, connected to the adapter cached in JavaslangPipes with the specified key
default com.aol.simple.react.stream.lazy.LazyReact	cpuStreamBuilder()
default <K,V> javaslang.control.Try<java.lang.Boolean>	enqueue(K key, V value) Add a value to an simple-react Async.Queue
default <K,T> com.aol.simple.react.stream.traits.LazyFutureStream<T>	ioFutureStream(K key) Get a LazyFutureStream optimized for IO operations, connected to the adapter cached in JavaslangPipes with the specified key
default com.aol.simple.react.stream.lazy.LazyReact	ioStreamBuilder()
default <T> javaslang.collection.Stream<T>	publish(org.reactivestreams.Publisher<T> publisher) Publish a reactive-streams publisher to a new Javaslang Stream
default <K,T> javaslang.collection.Stream<T>	sequentialStream(K key) Get a Javaslang Stream connected to the adapter cached in JavaslangPipes with the specified key
default <T> void	subsribe(javaslang.collection.Stream<T> s, org.reactivestreams.Subscriber<T> sub) Have a reactive-stream subscriber subscribe to a Javaslang Stream.
default <T> void	subsribe(javaslang.collection.Stream<T> s, org.reactivestreams.Subscriber<T> sub, java.util.concurrent.Executor exec) Have a reactive-stream subscriber subscribe to a Javaslang Stream asynchronously.
default <T> com.aol.simple.react.stream.traits.LazyFutureStream<T>	switchToCPU(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream) Switch LazyFutureStream into execution mode suitable for CPU bound execution (reuse cpuReactors task executor)
default <T> com.aol.simple.react.stream.traits.LazyFutureStream<T>	switchToIO(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream) Switch LazyFutureStream into execution mode suitable for IO (reuse ioReactors task executor)
default <T> javaslang.collection.Stream<T>	switchToSequential(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream) Switch a LazyFutureStream to a Javaslang Stream

Method Detail

enqueue

default <K,V> javaslang.control.Try<java.lang.Boolean> enqueue(K key,
                                                               V value)

Add a value to an simple-react Async.Queue

Parameters:

key - : identifier for registered Queue

value - : value to add to Queue

See Also:

Pipes.register(Object, com.aol.simple.react.async.Adapter)

publish

default <T> javaslang.collection.Stream<T> publish(org.reactivestreams.Publisher<T> publisher)

Publish a reactive-streams publisher to a new Javaslang Stream

Parameters:

publisher - to publish

Returns:

Stream subscribed to publisher

subsribe

default <T> void subsribe(javaslang.collection.Stream<T> s,
                          org.reactivestreams.Subscriber<T> sub)

Have a reactive-stream subscriber subscribe to a Javaslang Stream.

Parameters:

s - Stream to subscribe to

sub - Subscriber

subsribe

default <T> void subsribe(javaslang.collection.Stream<T> s,
                          org.reactivestreams.Subscriber<T> sub,
                          java.util.concurrent.Executor exec)

Have a reactive-stream subscriber subscribe to a Javaslang Stream asynchronously.

Parameters:

s - Stream to subscribe to

sub - Subscriber

exec - task executor for async operations

ioFutureStream

default <K,T> com.aol.simple.react.stream.traits.LazyFutureStream<T> ioFutureStream(K key)

Get a LazyFutureStream optimized for IO operations, connected to the adapter cached in JavaslangPipes with the specified key

Parameters:

key - of Adapter in JavaslangPipes

Returns:

IO Optimized LazyFutureStream

sequentialStream

default <K,T> javaslang.collection.Stream<T> sequentialStream(K key)

Get a Javaslang Stream connected to the adapter cached in JavaslangPipes with the specified key

Parameters:

key - of Adapter in JavaslangPipes

Returns:

Javaslang Stream connected to adapter

cpuFutureStream

default <K,T> com.aol.simple.react.stream.traits.LazyFutureStream<T> cpuFutureStream(K key)

Get a LazyFutureStream optimized for CPU operations, connected to the adapter cached in JavaslangPipes with the specified key

Parameters:

key - of Adapter in JavaslangPipes

Returns:

Javaslang Stream connected to adapter

ioStreamBuilder

default com.aol.simple.react.stream.lazy.LazyReact ioStreamBuilder()

Returns:

LazyReact Stream builder optimized for IO Operations

cpuStreamBuilder

default com.aol.simple.react.stream.lazy.LazyReact cpuStreamBuilder()

Returns:

LazyReact Stream builder optimized for CPU Operations

switchToSequential

default <T> javaslang.collection.Stream<T> switchToSequential(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream)

Switch a LazyFutureStream to a Javaslang Stream

Parameters:

stream - LazyFutureStream to convert

Returns:

Javaslang Stream

switchToIO

default <T> com.aol.simple.react.stream.traits.LazyFutureStream<T> switchToIO(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream)

Switch LazyFutureStream into execution mode suitable for IO (reuse ioReactors task executor)

Parameters:

stream - to convert to IO mode

Returns:

LazyFutureStream in IO mode

switchToCPU

default <T> com.aol.simple.react.stream.traits.LazyFutureStream<T> switchToCPU(com.aol.simple.react.stream.traits.LazyFutureStream<T> stream)

Switch LazyFutureStream into execution mode suitable for CPU bound execution (reuse cpuReactors task executor)

Parameters:

stream - to convert to CPU bound mode

Returns:

LazyFutureStream in CPU bound mode