Package rx.observables

Classes extending the Observable base reactive class, synchronous and asynchronous event generators.

See: Description

Class Summary

Class	Description
AsyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
BlockingObservable<T>	BlockingObservable is a variety of Observable that provides blocking operators.
ConnectableObservable<T>	A ConnectableObservable resembles an ordinary Observable, except that it does not begin emitting items when it is subscribed to, but only when its ConnectableObservable.connect() method is called.
GroupedObservable<K,T>	An Observable that has been grouped by key, the value of which can be obtained with GroupedObservable.getKey().
SyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that responds correctly to back pressure requests from subscribers.

Package rx.observables Description

Classes extending the Observable base reactive class, synchronous and asynchronous event generators.