Top Description Interfaces Classes

[default module]

Package rx.observers

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

Interface Summary

Modifier and Type	Interface and Description
public interface	AssertableSubscriber< the value type consumed by this Observer T> Interface for asserting the state of a sequence under testing with a `test()` method of a reactive base class.

Class Summary

Modifier and Type	Class and Description
public abstract class	AsyncCompletableSubscriber An abstract base class for CompletableSubscriber implementations that want to expose an unsubscription capability.
public class	Observers Helper methods and utilities for creating and working with `Observer` objects.
public class	SafeCompletableSubscriber Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.
public class	SafeSubscriber< the type of item expected by the `Subscriber` T> `SafeSubscriber` is a wrapper around `Subscriber` that ensures that the `Subscriber` complies with the Observable contract.
public class	SerializedObserver< the type of items expected to be observed by the `Observer` T> Enforces single-threaded, serialized, ordered execution of `onNext`, `onCompleted`, and `onError`.
public class	SerializedSubscriber< the type of items expected to be emitted to the `Subscriber` T> Enforces single-threaded, serialized, ordered execution of `onNext`, `onCompleted`, and `onError`.
public class	Subscribers Helper methods and utilities for creating and working with `Subscriber` objects.
public class	TestObserver< the observed value type T> Deprecated use the `TestSubscriber` instead. Observer usable for unit testing to perform assertions, inspect received events or wrap a mocked Observer.
public class	TestSubscriber< the value type 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`.