com.aol.micro.server.javaslang.reactive

Class JavaslangReactive

java.lang.Object

com.aol.micro.server.javaslang.reactive.JavaslangReactive

public class JavaslangReactive
extends java.lang.Object

Mixin / Trait for Reactive behaviour via simple-react

Constructor Summary

Constructors

Constructor and Description
JavaslangReactive()

Method Summary

Modifier and Type	Method and Description
static <T> javaslang.collection.Stream<T>	publishStream(org.reactivestreams.Publisher<T> publisher) Publish a reactive-streams publisher to a new Javaslang Stream
static <T> void	subsribeToTraversable(javaslang.collection.Traversable<T> s, org.reactivestreams.Subscriber<T> sub) Have a reactive-stream subscriber subscribe to a Javaslang Stream.
static <T> void	subsribeToValue(javaslang.Value<T> s, org.reactivestreams.Subscriber<T> sub)

Methods inherited from class java.lang.Object

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

Constructor Detail

JavaslangReactive

public JavaslangReactive()

Method Detail

publishStream

public static <T> javaslang.collection.Stream<T> publishStream(org.reactivestreams.Publisher<T> publisher)

Publish a reactive-streams publisher to a new Javaslang Stream

Parameters:

publisher - to publish

Returns:

Stream subscribed to publisher

subsribeToValue

public static <T> void subsribeToValue(javaslang.Value<T> s,
                                       org.reactivestreams.Subscriber<T> sub)

subsribeToTraversable

public static <T> void subsribeToTraversable(javaslang.collection.Traversable<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