See: Description
| Class | Description |
|---|---|
| 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 DefaultObserver.cancel() (synchronously) and calls DefaultObserver.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.
|
| Enum | Description |
|---|---|
| BaseTestConsumer.TestWaitStrategy |
Enumeration of default wait strategies when waiting for a specific number of
items in
BaseTestConsumer.awaitCount(int, Runnable). |