Package com.aol.cyclops2.types.reactive

Interface Summary

Interface	Description
Completable<T>	Created by johnmcclean on 26/01/2017.
FutureStreamSynchronousPublisher<T>	Reactive Streams publisher, that publishes on the calling thread
PushSubscriber<T>
ReactiveStreamsTerminalFutureOperations<T>	Interface for reactiveBuffer-streams based terminal operations, requires simple-react to be on the classpath.
ReactiveStreamsTerminalOperations<T>	Interface for reactiveBuffer-streams based terminal operations, requires simple-react to be on the classpath.

Class Summary

Class	Description
AsyncSubscriber<T>	A subscriber for Observable type Streams that avoid the overhead of applying backpressure.
Completable.CompletablePublisher<T>
QueueBasedSubscriber<T>	A reactiveBuffer-streams reactiveSubscriber, backed by a cyclops2-react async.Queue, for merging data from multiple publishers into a singleUnsafe Stream
QueueBasedSubscriber.Counter
ReactiveSubscriber<T>	A Subscriber for Observable type event driven Streams that implement backpressure via the reactiveBuffer-streams API
ReactiveTask	Class that represents an active reactiveBuffer-streams task
ValueSubscriber<T>	A reactiveBuffer-streams Subscriber that can take 1 value from a reactiveBuffer-streams publisher and convert it into various forms

Enum Summary

Enum	Description
BufferOverflowPolicy