Class | Description |
---|---|
BarrierStream | |
DeferredStream<T> |
A
Publisher supplier that will call the passed supplier on each subscribe call. |
ErrorStream<O,T extends Throwable> |
A Stream that emits a sigle error signal.
|
FutureStream<T> |
A Stream that emits a result of a
Future and then complete. |
GroupedStream<K,T> |
The Stream will complete or fail whever the parent groupBy action terminates itself.
|
IterableStream<T> |
A Stream that emits
Iterable values one by one and then complete. |
LiftStream<O,V> |
A Stream wrapper that defers a parent stream subscription to the child action subscribe() call.
|
MapStream<K,V> |
A SubscribableMap is an event-driven Map that signals logged operations to its subscribers.
|
MapStream.MutableSignal<K,V> | |
MapStream.Signal<K,V> | |
PeriodicTimerStream |
A Stream that emits
0 after an initial delay and ever incrementing long counter if the period argument is
specified. |
PublisherStream<T> |
A
Publisher wrapper that takes care of lazy subscribing. |
RangeStream |
A Stream that emits N
Long from the inclusive start value defined to the inclusive end and then
complete. |
SingleTimerStream |
A Stream that emits
0 after an initial delay and then complete
The SingleTimerStream will manage dedicated timers for new subscriber assigned via
this#subscribe(org.reactivestreams.Subscriber) . |
SingleValueStream<T> |
A Stream that emits only one value and then complete.
|
SupplierStream<T> |
A Stream that returns the result from
Supplier.get() everytime it is requested via
Subscription.request(long) . |
Enum | Description |
---|---|
MapStream.Operation |
Copyright © 2017. All rights reserved.