BasicFuseableConditionalSubscriber<T,R> |
Base class for a fuseable intermediate subscriber.
|
BasicFuseableSubscriber<T,R> |
Base class for a fuseable intermediate subscriber.
|
BlockingBaseSubscriber<T> |
|
BlockingFirstSubscriber<T> |
Blocks until the upstream signals its first value or completes.
|
BlockingLastSubscriber<T> |
Blocks until the upstream signals its last value or completes.
|
BlockingSubscriber<T> |
|
BoundedSubscriber<T> |
|
DeferredScalarSubscriber<T,R> |
A subscriber, extending a DeferredScalarSubscription,
that is unbounded-in and can generate 0 or 1 resulting value.
|
DisposableAutoReleaseSubscriber<T> |
Wraps lambda callbacks and when the upstream terminates or this subscriber gets disposed,
removes itself from a CompositeDisposable .
|
ForEachWhileSubscriber<T> |
|
FutureSubscriber<T> |
A Subscriber + Future that expects exactly one upstream value and provides it
via the (blocking) Future API.
|
InnerQueuedSubscriber<T> |
Subscriber that can fuse with the upstream and calls a support interface
whenever an event is available.
|
LambdaSubscriber<T> |
|
QueueDrainSubscriber<T,U,V> |
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
QueueDrainSubscriberPad0 |
Pads the header away from other fields.
|
QueueDrainSubscriberPad2 |
Pads away the wip from the other fields.
|
QueueDrainSubscriberPad3 |
Contains the requested field.
|
QueueDrainSubscriberPad4 |
Pads away the requested from the other fields.
|
QueueDrainSubscriberWip |
The WIP counter.
|
SinglePostCompleteSubscriber<T,R> |
Relays signals from upstream according to downstream requests and allows
signalling a final value followed by onComplete in a backpressure-aware manner.
|
StrictSubscriber<T> |
Ensures that the event flow between the upstream and downstream follow
the Reactive-Streams 1.0 specification by honoring the 3 additional rules
(which are omitted in standard operators due to performance reasons).
|
SubscriberResourceWrapper<T> |
|