See: Description
| Interface | Description |
|---|---|
| AssertableSubscriber<T> |
Interface for asserting the state of a sequence under testing with a
test()
method of a reactive base class. |
| Class | Description |
|---|---|
| AsyncCompletableSubscriber |
An abstract base class for CompletableSubscriber implementations that want to expose an unsubscription
capability.
|
| Observers |
Helper methods and utilities for creating and working with
Observer objects. |
| SafeCompletableSubscriber |
Wraps another CompletableSubscriber and handles exceptions thrown
from onError and onCompleted.
|
| SafeSubscriber<T> |
SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber
complies with the Observable contract. |
| SerializedObserver<T> |
Enforces single-threaded, serialized, ordered execution of
SerializedObserver.onNext(T), SerializedObserver.onCompleted(), and
SerializedObserver.onError(java.lang.Throwable). |
| SerializedSubscriber<T> |
Enforces single-threaded, serialized, ordered execution of
SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and
SerializedSubscriber.onError(java.lang.Throwable). |
| Subscribers |
Helper methods and utilities for creating and working with
Subscriber objects. |
| TestObserver<T> | Deprecated
use the
TestSubscriber instead. |
| TestSubscriber<T> |
A
TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform
assertions, inspect received events, or wrap a mocked Subscriber. |