| 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> |
|