Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.observables |
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
|
Class and Description |
---|
AsyncOnSubscribe
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
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() . |
SyncOnSubscribe
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
Class and Description |
---|
AsyncOnSubscribe
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
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() . |
SyncOnSubscribe
A utility class to create
OnSubscribe<T> functions that respond correctly to back
pressure requests from subscribers. |
Copyright © 2020. All rights reserved.