com.aol.cyclops.reactor.flux.pushable

Class MultipleFluxSource<T>

java.lang.Object

com.aol.cyclops.reactor.flux.pushable.MultipleFluxSource<T>

public class MultipleFluxSource<T>
extends java.lang.Object

Constructor Summary

Constructors

Constructor and Description
MultipleFluxSource(Queue<T> q)

Method Summary

Modifier and Type	Method and Description
reactor.core.publisher.Flux<T>	flux() Create a pushable Flux
LazyFutureStream<T>	futureStream(LazyReact s) Create a pushable LazyFutureStream using the supplied ReactPool
Topic<T>	getInput()
reactor.core.publisher.Mono<T>	mono() Create a pushable Mono
ReactiveSeq<T>	reactiveSeq() Create a pushable ReactiveSeq
java.util.stream.Stream<T>	stream() Create a pushable JDK 8 Stream

Methods inherited from class java.lang.Object

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

Constructor Detail

MultipleFluxSource

public MultipleFluxSource(Queue<T> q)

Method Detail

futureStream

public LazyFutureStream<T> futureStream(LazyReact s)

Create a pushable LazyFutureStream using the supplied ReactPool

Parameters:

s - React builder to use to create the Stream

Returns:

a Tuple2 with a Topic<T> and LazyFutureStream<T> - add data to the Queue to push it to the Stream

stream

public java.util.stream.Stream<T> stream()

Create a pushable JDK 8 Stream

Returns:

a Tuple2 with a Topic<T> and Stream<T> - add data to the Queue to push it to the Stream

reactiveSeq

public ReactiveSeq<T> reactiveSeq()

Create a pushable ReactiveSeq

Returns:

a Tuple2 with a Topic<T> and Seq<T> - add data to the Queue to push it to the Stream

flux

public reactor.core.publisher.Flux<T> flux()

Create a pushable Flux

Returns:

a Tuple2 with a Topic<T> and Flux<T> - add data to the Queue to push it to the Stream

mono

public reactor.core.publisher.Mono<T> mono()

Create a pushable Mono

Returns:

a Tuple2 with a Topic<T> and Mono<T> - add data to the Queue to push it to the Stream

getInput

public Topic<T> getInput()

Returns:

Topic used as input for any generated Streams