| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.annotations |
| Modifier and Type | Method and Description |
|---|---|
Observable |
Observable.doOnRequest(Action1
Modifies the source
Observable so that it invokes the given action when it receives a request for more items.
|
<R> Observable |
Observable.flatMap(Func1
Returns an Observable that applies a function to each item emitted or notification raised by the source Observable and then flattens the Observables returned from these functions and emits the resulting items, while limiting the maximum number of concurrent subscriptions to these Observables.
|
<R> Observable |
Observable.flatMap(Func1
Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an Observable, and then merging those resulting Observables and emitting the results of this merger, while limiting the maximum number of concurrent subscriptions to these Observables.
|
<U |
Observable.flatMap(Func1
Returns an Observable that emits the results of a specified function to the pair of values emitted by the source Observable and a specified collection Observable, while limiting the maximum number of concurrent subscriptions to these Observables.
|
Observable |
Observable.onBackpressureBuffer(long capacity)
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted.
|
Observable |
Observable.onBackpressureBuffer(long capacity, Action0
Instructs an Observable that is emitting items faster than its observer can consume them to buffer up to a given amount of items until they can be emitted.
|
| Modifier and Type | Class and Description |
|---|---|
interface |
Beta
Signifies that a public API (public class, method or field) is subject to incompatible changes, or even removal, in a future release.
|