Package rx.observers

Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.

Class Summary

Class	Description
AsyncCompletableSubscriber	An abstract base class for CompletableSubscriber implementations that want to expose an unsubscription capability.
AsyncCompletableSubscriber.Unsubscribed
Observers	Helper methods and utilities for creating and working with Observer objects.
SafeCompletableSubscriber	Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.
SafeSubscriber<T>	SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Observable contract.
SerializedObserver<T>	Enforces single-threaded, serialized, ordered execution of SerializedObserver.onNext(T), SerializedObserver.onCompleted(), and SerializedObserver.onError(java.lang.Throwable).
SerializedObserver.FastList
SerializedSubscriber<T>	Enforces single-threaded, serialized, ordered execution of SerializedSubscriber.onNext(T), SerializedSubscriber.onCompleted(), and SerializedSubscriber.onError(java.lang.Throwable).
Subscribers	Helper methods and utilities for creating and working with Subscriber objects.
TestObserver<T>	Deprecated. use the TestSubscriber insteand.
TestSubscriber<T>	A TestSubscriber is a variety of Subscriber that you can use for unit testing, to perform assertions, inspect received events, or wrap a mocked Subscriber.