Uses of Package
rx.observers
Packages that use rx.observers
Package
Description
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
Default wrappers and implementations for the base reactive consumer classes and interfaces;
utility classes for creating them from callbacks.
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.operatorsClassDescriptionEnforces single-threaded, serialized, ordered execution of
SerializedSubscriber.onNext(T)
,SerializedSubscriber.onCompleted()
, andSerializedSubscriber.onError(java.lang.Throwable)
. -
Classes in rx.observers used by rx.observablesClassDescriptionEnforces single-threaded, serialized, ordered execution of
SerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
. -
Classes in rx.observers used by rx.observersClassDescriptionA
TestSubscriber
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.subjectsClassDescriptionEnforces single-threaded, serialized, ordered execution of
SerializedObserver.onNext(T)
,SerializedObserver.onCompleted()
, andSerializedObserver.onError(java.lang.Throwable)
.