Package rx.observables

package rx.observables

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

Related Packages

Package	Description
rx	Base reactive classes: Observable, Single and Completable; base reactive consumers; other common base interfaces.

Classes

Class	Description
AsyncOnSubscribe<S,T>	A utility class to create OnSubscribe<T> functions that respond correctly to back pressure requests from subscribers.
AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T>	An implementation of AsyncOnSubscribe that delegates AsyncOnSubscribe.next(Object, long, Observer), AsyncOnSubscribe.generateState(), and AsyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.
AsyncOnSubscribe.AsyncOuterManager<S,T>
AsyncOnSubscribe.UnicastSubject<T>
AsyncOnSubscribe.UnicastSubject.State<T>
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 respond correctly to back pressure requests from subscribers.
SyncOnSubscribe.SubscriptionProducer<S,T>	Contains the producer loop that reacts to downstream requests of work.
SyncOnSubscribe.SyncOnSubscribeImpl<S,T>	An implementation of SyncOnSubscribe that delegates invalid reference SyncOnSubscribe#next(Object, Subscriber) , SyncOnSubscribe.generateState(), and SyncOnSubscribe.onUnsubscribe(Object) to provided functions/closures.