Uses of Class
io.reactivex.rxjava3.subscribers.TestSubscriber
Packages that use TestSubscriber
Package
Description
Base reactive classes:
Flowable
, Observable
,
Single
, Maybe
and
Completable
; base reactive consumers;
other common base interfaces.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.-
Uses of TestSubscriber in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return TestSubscriberModifier and TypeMethodDescriptionfinal @NonNull TestSubscriber
<T> Flowable.test()
final @NonNull TestSubscriber
<T> Flowable.test
(long initialRequest) Creates aTestSubscriber
with the given initial request amount and subscribes it to thisFlowable
.final @NonNull TestSubscriber
<T> Flowable.test
(long initialRequest, boolean cancel) Creates aTestSubscriber
with the given initial request amount, optionally cancels it before the subscription and subscribes it to thisFlowable
. -
Uses of TestSubscriber in io.reactivex.rxjava3.subscribers
Methods in io.reactivex.rxjava3.subscribers that return TestSubscriberModifier and TypeMethodDescriptionprotected final TestSubscriber
<T> TestSubscriber.assertSubscribed()
Assert that theonSubscribe(Subscription)
method was called exactly once.static <T> @NonNull TestSubscriber
<T> TestSubscriber.create()
Creates aTestSubscriber
withLong.MAX_VALUE
initial request amount.static <T> @NonNull TestSubscriber
<T> TestSubscriber.create
(long initialRequested) Creates aTestSubscriber
with the given initial request amount.static <T> TestSubscriber
<T> Constructs a forwardingTestSubscriber
.final TestSubscriber
<T> TestSubscriber.requestMore
(long n) Callsrequest(long)
and returns this.