Uses of Class
io.reactivex.rxjava3.subscribers.TestSubscriber
-
Packages that use TestSubscriber Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable
,Observable
,Single
,Maybe
andCompletable
; base reactive consumers; other common base interfaces.io.reactivex.rxjava3.subscribers Default wrappers and implementations forSubscriber
-based consumer classes and interfaces, including disposable (DisposableSubscriber
) and resource-tracking (ResourceSubscriber
) variants and theTestSubscriber
that allows unit testingFlowable
-based flows. -
-
Uses of TestSubscriber in io.reactivex.rxjava3.core
Methods in io.reactivex.rxjava3.core that return TestSubscriber Modifier and Type Method Description @NonNull TestSubscriber<T>
Flowable. test()
@NonNull TestSubscriber<T>
Flowable. test(long initialRequest)
Creates aTestSubscriber
with the given initial request amount and subscribes it to thisFlowable
.@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 TestSubscriber Modifier and Type Method Description protected 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>
TestSubscriber. create(@NonNull org.reactivestreams.Subscriber<? super T> delegate)
Constructs a forwardingTestSubscriber
.TestSubscriber<T>
TestSubscriber. requestMore(long n)
Callsrequest(long)
and returns this.
-