Package rx.observers

Class Summary

Class

Description

Observers

Helper methods and utilities for creating and working with Observer objects.

SafeSubscriber<T>

SafeSubscriber is a wrapper around Subscriber that ensures that the Subscriber complies with the Rx contract.

SerializedObserver<T>

Enforces single-threaded, serialized, ordered execution of SerializedObserver.onNext(T), SerializedObserver.onCompleted(), and SerializedObserver.onError(java.lang.Throwable).

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>

Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.

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.