rxjava 1.3.8 · rx.observables

Class Summary

Modifier and Type	Class and Description
public abstract class	AsyncOnSubscribe< the type of the user-define state used in `generateState(S)` , `next(S, Long, Observer)`, and `onUnsubscribe(S)`. S, the type of `Subscribers` that will be compatible with `this`. T> A utility class to create `OnSubscribe<T>` functions that respond correctly to back pressure requests from subscribers.
public class	BlockingObservable< the type of item emitted by the `BlockingObservable` T> `BlockingObservable` is a variety of `Observable` that provides blocking operators.
public abstract class	ConnectableObservable< the type of items emitted by the `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 `connect` method is called.
public class	GroupedObservable< the type of the key K, the type of the items emitted by the `GroupedObservable` T> An `Observable` that has been grouped by key, the value of which can be obtained with `getKey()`.
public abstract class	SyncOnSubscribe< the type of the user-define state used in `generateState(S)` , `next(S, Subscriber)`, and `onUnsubscribe(S)`. S, the type of `Subscribers` that will be compatible with `this`. T> A utility class to create `OnSubscribe<T>` functions that responds correctly to back pressure requests from subscribers.