| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.functions | |
| rx.internal.operators |
Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1 |
Observable.combineLatest(Observable
Combines five source Observables by emitting an item that aggregates the latest values of each of the source Observables each time an item is received from any of the source Observables, where this aggregation is defined by a specified function.
|
static <T1 |
Observable.zip(Observable
Returns an Observable that emits the results of a specified combiner function applied to combinations of five items emitted, in sequence, by five other Observables.
|
| Modifier and Type | Method and Description |
|---|---|
static <T1 |
Actions.toFunc(Action5
Converts an
Action5 to a function that calls the action and returns
null.
|
static <T1 |
Actions.toFunc(Action5
Converts an
Action5 to a function that calls the action and returns a specified value.
|
| Modifier and Type | Method and Description |
|---|---|
static <T0 |
Functions.fromFunc(Func5
|
| Constructor and Description | |
|---|---|
OperatorZip(Func5
|