Package | Description |
---|---|
rx |
Rx Observables
|
rx.observables |
Class and Description |
---|
BlockingObservable
BlockingObservable is a variety of Observable that provides blocking operators. |
ConnectableObservable
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
An
Observable that has been grouped by key, the value of which can be obtained with GroupedObservable.getKey() . |
Class and Description |
---|
AbstractOnSubscribe
Abstract base class for the
Observable.OnSubscribe interface that helps you build Observable sources one
onNext at a time, and automatically supports unsubscription and backpressure. |
AbstractOnSubscribe.SubscriptionState
Represents a per-subscription state for the
AbstractOnSubscribe operation. |
BlockingObservable
BlockingObservable is a variety of Observable that provides blocking operators. |
GroupedObservable
An
Observable that has been grouped by key, the value of which can be obtained with GroupedObservable.getKey() . |
Copyright © 2015. All Rights Reserved.