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 and Completable; base reactive consumers; other common base interfaces.
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.

Uses of TestSubscriber in io.reactivex.rxjava3.core

Methods in io.reactivex.rxjava3.core that return TestSubscriber

Modifier and Type	Method	Description
final @NonNull TestSubscriber<T>	Flowable.test()	Creates a TestSubscriber that requests Long.MAX_VALUE and subscribes it to this Flowable.
final @NonNull TestSubscriber<T>	Flowable.test(long initialRequest)	Creates a TestSubscriber with the given initial request amount and subscribes it to this Flowable.
final @NonNull TestSubscriber<T>	Flowable.test(long initialRequest, boolean cancel)	Creates a TestSubscriber with the given initial request amount, optionally cancels it before the subscription and subscribes it to this Flowable.

Uses of TestSubscriber in io.reactivex.rxjava3.subscribers

Subclasses with type arguments of type TestSubscriber in io.reactivex.rxjava3.subscribers

Modifier and Type	Class	Description
class	TestSubscriber<T>	A Subscriber implementation that records events and allows making assertions about them.

Methods in io.reactivex.rxjava3.subscribers that return TestSubscriber

Modifier and Type	Method	Description
protected final TestSubscriber<T>	TestSubscriber.assertSubscribed()	Assert that the TestSubscriber.onSubscribe(Subscription) method was called exactly once.
static <T> @NonNull TestSubscriber<T>	TestSubscriber.create()	Creates a TestSubscriber with Long.MAX_VALUE initial request amount.
static <T> @NonNull TestSubscriber<T>	TestSubscriber.create(long initialRequested)	Creates a TestSubscriber with the given initial request amount.
static <T> TestSubscriber<T>	TestSubscriber.create(@NonNull org.reactivestreams.Subscriber<? super T> delegate)	Constructs a forwarding TestSubscriber.
final TestSubscriber<T>	TestSubscriber.requestMore(long n)	Calls TestSubscriber.request(long) and returns this.