Package rx.observables
package rx.observables
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
-
ClassesClassDescriptionAsyncOnSubscribe<S,
T> A utility class to createOnSubscribe<T>
functions that respond correctly to back pressure requests from subscribers.An implementation of AsyncOnSubscribe that delegatesAsyncOnSubscribe.next(Object, long, Observer)
,AsyncOnSubscribe.generateState()
, andAsyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.BlockingObservable
is a variety ofObservable
that provides blocking operators.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.Contains the producer loop that reacts to downstream requests of work.An implementation of SyncOnSubscribe that delegatesinvalid reference
SyncOnSubscribe#next(Object, Subscriber)
SyncOnSubscribe.generateState()
, andSyncOnSubscribe.onUnsubscribe(Object)
to provided functions/closures.