Uses of Package
rx.observables
-
Packages that use rx.observables Package Description rx Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.rx.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.rx.internal.util rx.observables Classes extending the Observable base reactive class, synchronous and asynchronous event generators. -
Classes in rx.observables used by rx Class Description AsyncOnSubscribe A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.BlockingObservable BlockingObservable
is a variety ofObservable
that provides blocking operators.ConnectableObservable 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.GroupedObservable AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.SyncOnSubscribe A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers. -
Classes in rx.observables used by rx.internal.operators Class Description ConnectableObservable 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.GroupedObservable AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
. -
Classes in rx.observables used by rx.internal.util Class Description ConnectableObservable 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. -
Classes in rx.observables used by rx.observables Class Description AsyncOnSubscribe A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.AsyncOnSubscribe.UnicastSubject AsyncOnSubscribe.UnicastSubject.State BlockingObservable BlockingObservable
is a variety ofObservable
that provides blocking operators.GroupedObservable AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.SyncOnSubscribe A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.