Uses of Package
rx.observables
Packages that use rx.observables
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
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.
-
Classes in rx.observables used by rxClassDescriptionA utility class to create
OnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.BlockingObservable
is a variety ofObservable
that provides blocking operators.AConnectableObservable
resembles an ordinaryObservable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()
method is called.AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers. -
Classes in rx.observables used by rx.internal.operatorsClassDescriptionA
ConnectableObservable
resembles an ordinaryObservable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()
method is called.AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
. -
Classes in rx.observables used by rx.internal.utilClassDescriptionA
ConnectableObservable
resembles an ordinaryObservable
, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()
method is called. -
Classes in rx.observables used by rx.observablesClassDescriptionA utility class to create
OnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.BlockingObservable
is a variety ofObservable
that provides blocking operators.AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.