Package rx.observers
package rx.observers
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
-
ClassesClassDescriptionAn abstract base class for CompletableSubscriber implementations that want to expose an unsubscription capability.Helper methods and utilities for creating and working with
Observer
objects.Wraps another CompletableSubscriber and handles exceptions thrown from onError and onCompleted.SafeSubscriber
is a wrapper aroundSubscriber
that ensures that theSubscriber
complies with the Observable contract.Enforces single-threaded, serialized, ordered execution ofSerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
.Enforces single-threaded, serialized, ordered execution ofSerializedSubscriber.onNext(T)
,SerializedSubscriber.onCompleted()
, andSerializedSubscriber.onError(java.lang.Throwable)
.Helper methods and utilities for creating and working withSubscriber
objects.TestObserver<T>Deprecated.ATestSubscriber
is a variety ofSubscriber
that you can use for unit testing, to perform assertions, inspect received events, or wrap a mockedSubscriber
.
TestSubscriber
insteand.