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