| BaseTestConsumer<T, U extends BaseTestConsumer<T, U>> | Base class with shared infrastructure to support TestSubscriber and TestObserver. |
| DefaultObserver<T> | Abstract base implementation of an Observer with support for cancelling a
subscription via cancel() (synchronously) and calls onStart()
when the subscription happens. |
| DisposableCompletableObserver | An abstract CompletableObserver that allows asynchronous cancellation by implementing Disposable. |
| DisposableMaybeObserver<T> | An abstract MaybeObserver that allows asynchronous cancellation by implementing Disposable. |
| DisposableObserver<T> | An abstract Observer that allows asynchronous cancellation by implementing Disposable. |
| DisposableSingleObserver<T> | An abstract SingleObserver that allows asynchronous cancellation by implementing Disposable. |
| ResourceCompletableObserver | An abstract CompletableObserver that allows asynchronous cancellation of its subscription and associated resources. |
| ResourceMaybeObserver<T> | An abstract MaybeObserver that allows asynchronous cancellation of its subscription and associated resources. |
| ResourceObserver<T> | An abstract Observer that allows asynchronous cancellation of its subscription and associated resources. |
| ResourceSingleObserver<T> | An abstract SingleObserver that allows asynchronous cancellation of its subscription
and the associated resources. |
| SafeObserver<T> | Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access). |
| SerializedObserver<T> | Serializes access to the onNext, onError and onComplete methods of another Observer. |
| TestObserver<T> | An Observer that records events and allows making assertions about them. |
| BaseTestConsumer.TestWaitStrategy | Enumeration of default wait strategies when waiting for a specific number of
items in awaitCount(int, Runnable). |