Top Description Interfaces Classes

[default module]

Package io.reactivex.rxjava3.observers

Default wrappers and implementations for observer-based consumer classes and interfaces, including disposable and resource-tracking variants and the TestObserver that allows unit testing Observable-, Single-, Maybe- and Completable-based flows.

Available observer variants

The available observer types.
Reactive type	Base interface	Simple	Disposable	Resource
`Observable`	`Observer`	`DefaultObserver`	`DisposableObserver`	`DisposableObserver`
`Maybe`	`MaybeObserver`	N/A	`DisposableMaybeObserver`	`DisposableMaybeObserver`
`Single`	`SingleObserver`	N/A	`DisposableSingleObserver`	`DisposableSingleObserver`
`Completable`	`CompletableObserver`	N/A	`DisposableCompletableObserver`	`DisposableCompletableObserver`

Interface Summary

Modifier and Type	Interface and Description
public interface	LambdaConsumerIntrospection An interface that indicates that the implementing type is composed of individual components and exposes information about their behavior.

Class Summary

Modifier and Type	Class and Description
public abstract class	BaseTestConsumer< the value type consumed T, the subclass of this `BaseTestConsumer` U extends BaseTestConsumer<T, U>> Base class with shared infrastructure to support `TestSubscriber` and `TestObserver`.
public abstract class	DefaultObserver< the value type T> Abstract base implementation of an `Observer` with support for cancelling a subscription via `cancel()` (synchronously) and calls `onStart()` when the subscription happens.
public abstract class	DisposableCompletableObserver An abstract `CompletableObserver` that allows asynchronous cancellation by implementing Disposable.
public abstract class	DisposableMaybeObserver< the received value type T> An abstract `MaybeObserver` that allows asynchronous cancellation by implementing `Disposable`.
public abstract class	DisposableObserver< the received value type T> An abstract `Observer` that allows asynchronous cancellation by implementing `Disposable`.
public abstract class	DisposableSingleObserver< the received value type T> An abstract `SingleObserver` that allows asynchronous cancellation by implementing `Disposable`.
public abstract class	ResourceCompletableObserver An abstract `CompletableObserver` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceMaybeObserver< the value type T> An abstract `MaybeObserver` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceObserver< the value type T> An abstract `Observer` that allows asynchronous cancellation of its subscription and associated resources.
public abstract class	ResourceSingleObserver< the value type T> An abstract `SingleObserver` that allows asynchronous cancellation of its subscription and the associated resources.
public class	SafeObserver< the value type T> Wraps another `Observer` and ensures all `onXXX` methods conform the protocol (except the requirement for serialized access).
public class	SerializedObserver< the value type T> Serializes access to the `Observer#onNext(Object)`, `Observer#onError(Throwable)` and `Observer#onComplete()` methods of another `Observer`.
public class	TestObserver< the value type T> An `Observer`, `MaybeObserver`, `SingleObserver` and `CompletableObserver` composite that can record events from `Observable`s, `Maybe`s, `Single`s and `Completable`s and allows making assertions about them.