Default wrappers and implementations for Subscriber-based consumer classes and interfaces;
utility classes for creating them from callbacks.
Classes
DefaultSubscriber<T> |
Abstract base implementation of a org.reactivestreams.Subscriber Subscriber with
support for requesting via request(long) , cancelling via
via cancel() (both synchronously) and calls onStart()
when the subscription happens. |
DisposableSubscriber<T> |
An abstract Subscriber that allows asynchronous, external cancellation by implementing Disposable. |
ResourceSubscriber<T> |
An abstract Subscriber that allows asynchronous cancellation of its
subscription and associated resources. |
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. |
TestSubscriber<T> |
A subscriber that records events and allows making assertions about them. |