Package io.reactivex.rxjava3.subscribers

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

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 Subscriber.onNext(Object), Subscriber.onError(Throwable) and Subscriber.onComplete() methods of another Subscriber.
TestSubscriber<T>	A Subscriber implementation that records events and allows making assertions about them.

Enum Summary

Enum	Description
TestSubscriber.EmptySubscriber	A subscriber that ignores all events and does not report errors.