| Class | Description |
|---|---|
| NbpAsyncObserver<T> |
An abstract Subscriber implementation that allows asynchronous cancellation of its
subscription.
|
| NbpObservers |
Utility class to create Observers from lambdas.
|
| NbpSafeSubscriber<T> |
Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
|
| NbpSerializedSubscriber<T> |
Serializes access to the onNext, onError and onComplete methods of another Subscriber.
|
| NbpSubscribers |
Utility class to construct various resource-holding and disposable Subscribers from lambdas.
|
| NbpTestSubscriber<T> |
A subscriber that records events and allows making assertions about them.
|