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 withObserver
objects.SafeCompletableSubscriber Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.SafeSubscriber<T> SafeSubscriber
is a wrapper aroundSubscriber
that ensures that theSubscriber
complies with the Observable contract.SerializedObserver<T> Enforces single-threaded, serialized, ordered execution ofSerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
.SerializedObserver.FastList SerializedSubscriber<T> Enforces single-threaded, serialized, ordered execution ofSerializedSubscriber.onNext(T)
,SerializedSubscriber.onCompleted()
, andSerializedSubscriber.onError(java.lang.Throwable)
.Subscribers Helper methods and utilities for creating and working withSubscriber
objects.TestObserver<T> Deprecated. use theTestSubscriber
insteand.TestSubscriber<T> ATestSubscriber
is a variety ofSubscriber
that you can use for unit testing, to perform assertions, inspect received events, or wrap a mockedSubscriber
.