Package io.reactivex.rxjava4.subscribers

package io.reactivex.rxjava4.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.

Classes

Class	Description
DefaultSubscriber<T>	Abstract base implementation of a 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 Flow.Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
SerializedSubscriber<T>	Serializes access to the Flow.Subscriber.onNext(Object), Flow.Subscriber.onError(Throwable) and Flow.Subscriber.onComplete() methods of another Flow.Subscriber.
TestSubscriber<T>	A Flow.Subscriber implementation that records events and allows making assertions about them.