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
BaseTestConsumerBaseTestConsumer>	Base class with shared infrastructure to support TestSubscriber and TestObserver.
DefaultObserver	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	An abstract MaybeObserver that allows asynchronous cancellation by implementing Disposable.
DisposableObserver	An abstract Observer that allows asynchronous cancellation by implementing Disposable.
DisposableSingleObserver	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	An abstract MaybeObserver that allows asynchronous cancellation of its subscription and associated resources.
ResourceObserver	An abstract Observer that allows asynchronous cancellation of its subscription and associated resources.
ResourceSingleObserver	An abstract SingleObserver that allows asynchronous cancellation of its subscription and the associated resources.
SafeObserver	Wraps another Subscriber and ensures all onXXX methods conform the protocol (except the requirement for serialized access).
SerializedObserver	Serializes access to the onNext, onError and onComplete methods of another Observer.
TestObserver	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.