Default wrappers and implementations for Subscriber-based consumer classes and interfaces;
utility classes for creating them from callbacks.
||Abstract base implementation of a org.reactivestreams.Subscriber Subscriber with
support for requesting via
request(long), cancelling via
cancel() (both synchronously) and calls
when the subscription happens.
||An abstract Subscriber that allows asynchronous, external cancellation by implementing Disposable.
||An abstract Subscriber that allows asynchronous cancellation of its
subscription and associated resources.
||Wraps another Subscriber and ensures all onXXX methods conform the protocol
(except the requirement for serialized access).
||Serializes access to the onNext, onError and onComplete methods of another Subscriber.
||A subscriber that records events and allows making assertions about them.