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.