| Interface | Description |
|---|---|
| ConditionalSubscriber<T> |
An Subscriber with an additional onNextIf(T) method that
tells the caller the specified value has been accepted or
not.
|
| Class | Description |
|---|---|
| BlockingSubscriber<T> | |
| DisposableSubscriber<T> |
An abstract subscription that allows asynchronous cancellation.
|
| FullArbiterSubscriber<T> |
Subscriber that communicates with a FullArbiter.
|
| LambdaSubscriber<T> | |
| NbpFullArbiterSubscriber<T> |
Subscriber that communicates with a FullArbiter.
|
| QueueDrainSubscriber<T,U,V> |
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
| SubscriptionLambdaSubscriber<T> | |
| ToNotificationSubscriber<T> |
| Enum | Description |
|---|---|
| CancelledSubscriber |
A subscriber that cancels the subscription sent to it
and ignores all events (onError is forwarded to RxJavaPlugins though).
|
| EmptySubscriber |
A subscriber that ignores all events (onError is forwarded to RxJavaPlugins though).
|