Package io.reactivex.subscribers

Default wrappers and implementations for Subscriber-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestSubscriber that allows unit testing Flowable-based flows.

See: Description

Class Summary

Class	Description
DefaultSubscriber<T>	Abstract base implementation of a Subscriber with support for requesting via DefaultSubscriber.request(long), cancelling via via DefaultSubscriber.cancel() (both synchronously) and calls DefaultSubscriber.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.

Package io.reactivex.subscribers Description

Default wrappers and implementations for Subscriber-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestSubscriber that allows unit testing Flowable-based flows.