Package io.reactivex.rxjava3.subscribers
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.-
ClassDescriptionAbstract base implementation of a
Subscriber
with support for requesting viaDefaultSubscriber.request(long)
, cancelling via viaDefaultSubscriber.cancel()
(both synchronously) and callsDefaultSubscriber.onStart()
when the subscription happens.An abstract Subscriber that allows asynchronous, external cancellation by implementingDisposable
.An abstract Subscriber that allows asynchronous cancellation of its subscription and associated resources.Wraps anotherSubscriber
and ensures allonXXX
methods conform the protocol (except the requirement for serialized access).Serializes access to theSubscriber.onNext(Object)
,Subscriber.onError(Throwable)
andSubscriber.onComplete()
methods of anotherSubscriber
.ASubscriber
implementation that records events and allows making assertions about them.A subscriber that ignores all events and does not report errors.