Package io.reactivex.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.

See: Description

Interface Summary

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

Class Summary

Class	Description
BaseTestConsumer<T,U extends BaseTestConsumer<T,U>>	Base class with shared infrastructure to support TestSubscriber and TestObserver.
DefaultObserver<T>	Abstract base implementation of an Observer with support for cancelling a subscription via DefaultObserver.cancel() (synchronously) and calls DefaultObserver.onStart() when the subscription happens.
DisposableCompletableObserver	An abstract CompletableObserver that allows asynchronous cancellation by implementing Disposable.
DisposableMaybeObserver<T>	An abstract MaybeObserver that allows asynchronous cancellation by implementing Disposable.
DisposableObserver<T>	An abstract Observer that allows asynchronous cancellation by implementing Disposable.
DisposableSingleObserver<T>	An abstract SingleObserver that allows asynchronous cancellation by implementing Disposable.
ResourceCompletableObserver	An abstract CompletableObserver that allows asynchronous cancellation of its subscription and associated resources.
ResourceMaybeObserver<T>	An abstract MaybeObserver that allows asynchronous cancellation of its subscription and associated resources.
ResourceObserver<T>	An abstract Observer that allows asynchronous cancellation of its subscription and associated resources.
ResourceSingleObserver<T>	An abstract SingleObserver that allows asynchronous cancellation of its subscription and the associated resources.
SafeObserver<T>	Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
SerializedObserver<T>	Serializes access to the onNext, onError and onComplete methods of another Observer.
TestObserver<T>	An Observer that records events and allows making assertions about them.

Enum Summary

Enum	Description
BaseTestConsumer.TestWaitStrategy	Enumeration of default wait strategies when waiting for a specific number of items in BaseTestConsumer.awaitCount(int, Runnable).

Package io.reactivex.observers Description

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.