Package rx.observables
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
-
Class Summary Class Description AsyncOnSubscribe<S,T> A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.AsyncOnSubscribe.AsyncOnSubscribeImpl<S,T> An implementation of AsyncOnSubscribe that delegatesAsyncOnSubscribe.next(Object, long, Observer)
,AsyncOnSubscribe.generateState()
, andAsyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.AsyncOnSubscribe.AsyncOuterManager<S,T> AsyncOnSubscribe.UnicastSubject<T> AsyncOnSubscribe.UnicastSubject.State<T> BlockingObservable<T> BlockingObservable
is a variety ofObservable
that provides blocking operators.ConnectableObservable<T> 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<K,T> AnObservable
that has been grouped by key, the value of which can be obtained withGroupedObservable.getKey()
.SyncOnSubscribe<S,T> A utility class to createOnSubscribe<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 delegatesSyncOnSubscribe#next(Object, Subscriber)
,SyncOnSubscribe.generateState()
, andSyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.