Uses of Package
rx.observers
-
Packages that use rx.observers Package Description rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.observables Classes extending the Observable base reactive class, synchronous and asynchronous event generators.rx.observers Default wrappers and implementations for the base reactive consumer classes and interfaces; utility classes for creating them from callbacks.rx.subjects Classes extending the Observable base reactive class and implementing the Observer interface at the same time (aka hot Observables). -
Classes in rx.observers used by rx.internal.operators Class Description SerializedSubscriber Enforces single-threaded, serialized, ordered execution ofSerializedSubscriber.onNext(T)
,SerializedSubscriber.onCompleted()
, andSerializedSubscriber.onError(java.lang.Throwable)
. -
Classes in rx.observers used by rx.observables Class Description SerializedObserver Enforces single-threaded, serialized, ordered execution ofSerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
. -
Classes in rx.observers used by rx.observers Class Description AsyncCompletableSubscriber.Unsubscribed SerializedObserver.FastList TestSubscriber ATestSubscriber
is a variety ofSubscriber
that you can use for unit testing, to perform assertions, inspect received events, or wrap a mockedSubscriber
. -
Classes in rx.observers used by rx.subjects Class Description SerializedObserver Enforces single-threaded, serialized, ordered execution ofSerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
.