| 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 <T |
Observable.combineLatest(List
Combines a list of 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 <R> Observable |
Observable.zip(Iterable
Returns an Observable that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an Iterable of other Observables.
|
static <R> Observable |
Observable.zip(Observable
Returns an Observable that emits the results of a specified combiner function applied to combinations of
n items emitted, in sequence, by the
n Observables emitted by a specified Observable.
|
| Modifier and Type | Method and Description |
|---|---|
static FuncN |
Functions.fromAction(Action0
|
static <T0> FuncN |
Functions.fromAction(Action1
|
static <T0 |
Functions.fromAction(Action2
|
static <T0 |
Functions.fromAction(Action3
|
static <R> FuncN |
Functions.fromFunc(Func0
|
static <T0 |
Functions.fromFunc(Func1
|
static <T0 |
Functions.fromFunc(Func2
|
static <T0 |
Functions.fromFunc(Func3
|
static <T0 |
Functions.fromFunc(Func4
|
static <T0 |
Functions.fromFunc(Func5
|
static <T0 |
Functions.fromFunc(Func6
|
static <T0 |
Functions.fromFunc(Func7
|
static <T0 |
Functions.fromFunc(Func8
|
static <T0 |
Functions.fromFunc(Func9
|
static FuncN |
Actions.toFunc(ActionN
Converts an
ActionN to a function that calls the action and returns
null.
|
static <R> FuncN |
Actions.toFunc(ActionN
Converts an
ActionN to a function that calls the action and returns a specified value.
|
| Constructor and Description | |
|---|---|
OnSubscribeCombineLatest(List
|
|
OperatorZip(FuncN
|