Uses of Class
io.reactivex.rxjava3.subscribers.TestSubscriber
-
Packages that use TestSubscriber Package Description io.reactivex.rxjava3.core Base reactive classes:Flowable,Observable,Single,MaybeandCompletable; 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 theTestSubscriberthat 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 aTestSubscriberwith the given initial request amount and subscribes it to thisFlowable.@NonNull TestSubscriber<T>Flowable. test(long initialRequest, boolean cancel)Creates aTestSubscriberwith 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 aTestSubscriberwithLong.MAX_VALUEinitial request amount.static <T> @NonNull TestSubscriber<T>TestSubscriber. create(long initialRequested)Creates aTestSubscriberwith 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.
-