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.BlockingObservableis a variety ofObservablethat provides blocking operators.AConnectableObservableresembles an ordinaryObservable, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()method is called.AnObservablethat 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
ConnectableObservableresembles an ordinaryObservable, except that it does not begin emitting items when it is subscribed to, but only when itsConnectableObservable.connect()method is called.AnObservablethat has been grouped by key, the value of which can be obtained withGroupedObservable.getKey(). -
Classes in rx.observables used by rx.internal.utilClassDescriptionA
ConnectableObservableresembles 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.BlockingObservableis a variety ofObservablethat provides blocking operators.AnObservablethat 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.