| Interface | Description |
|---|---|
| NbpConditionalSubscriber<T> |
An Subscriber with an additional onNextIf(T) method that
tells the caller the specified value has been accepted or
not.
|
| Class | Description |
|---|---|
| NbpBlockingSubscriber<T> | |
| NbpDisposableSubscriber<T> |
An abstract subscription that allows asynchronous cancellation.
|
| NbpLambdaSubscriber<T> | |
| NbpQueueDrainSubscriber<T,U,V> |
Abstract base class for subscribers that hold another subscriber, a queue
and requires queue-drain behavior.
|
| NbpSubscriptionLambdaSubscriber<T> | |
| NbpToNotificationSubscriber<T> |
| Enum | Description |
|---|---|
| NbpCancelledSubscriber |
A subscriber that cancels the subscription sent to it
and ignores all events (onError is forwarded to RxJavaPlugins though).
|
| NbpEmptySubscriber |
A subscriber that ignores all events (onError is forwarded to RxJavaPlugins though).
|