| Package | Description |
|---|---|
| rx |
Rx Observables
|
| rx.functions | |
| rx.observables |
| Modifier and Type | Method and Description |
|---|---|
<R> Observable |
Observable.collect(Func0
Collects items emitted by the source Observable into a single mutable data structure and returns an Observable that emits this structure.
|
| Modifier and Type | Method and Description |
|---|---|
static <T0 |
Functions.fromAction(Action2
|
static <T1 |
Actions.toFunc(Action2
Converts an
Action2 to a function that calls the action and returns
null.
|
static <T1 |
Actions.toFunc(Action2
Converts an
Action2 to a function that calls the action and returns a specified value.
|
| Modifier and Type | Method and Description |
|---|---|
static <S |
SyncOnSubscribe.createSingleState(Func0
Generates a synchronous
SyncOnSubscribe that calls the provided
next function to generate data to downstream subscribers.
|
static <S |
SyncOnSubscribe.createSingleState(Func0
Generates a synchronous
SyncOnSubscribe that calls the provided
next function to generate data to downstream subscribers.
|
static <T> Observable |
AsyncOnSubscribe.createStateless(Action2
Generates a synchronous
AsyncOnSubscribe that calls the provided
next function to generate data to downstream subscribers.
|
static <T> Observable |
AsyncOnSubscribe.createStateless(Action2
Generates a synchronous
AsyncOnSubscribe that calls the provided
next function to generate data to downstream subscribers.
|