Package | Description |
---|---|
rx |
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
|
rx.functions |
Functional interfaces of functions and actions of arity 0 to 9 and related
utility classes.
|
rx.observables |
Classes extending the Observable base reactive class, synchronous and
asynchronous event generators.
|
Modifier and Type | Method and Description |
---|---|
<R> Observable<R> |
Observable.collect(Func0<R> stateFactory,
Action2<R,? super T> collector)
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,T1> FuncN<Void> |
Functions.fromAction(Action2<? super T0,? super T1> f)
|
static <T1,T2> Func2<T1,T2,Void> |
Actions.toFunc(Action2<T1,T2> action)
Converts an
Action2 to a function that calls the action and returns null . |
static <T1,T2,R> Func2<T1,T2,R> |
Actions.toFunc(Action2<T1,T2> action,
R result)
Converts an
Action2 to a function that calls the action and returns a specified value. |
Modifier and Type | Method and Description |
---|---|
static <S,T> SyncOnSubscribe<S,T> |
SyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action2<? super S,? super Observer<? super T>> next)
Generates a synchronous
SyncOnSubscribe that calls the provided next function
to generate data to downstream subscribers. |
static <S,T> SyncOnSubscribe<S,T> |
SyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action2<? super S,? super Observer<? super T>> next,
Action1<? super S> onUnsubscribe)
Generates a synchronous
SyncOnSubscribe that calls the provided next function
to generate data to downstream subscribers. |
static <T> AsyncOnSubscribe<Void,T> |
AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next)
Generates a synchronous
AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers. |
static <T> AsyncOnSubscribe<Void,T> |
AsyncOnSubscribe.createStateless(Action2<Long,? super Observer<Observable<? extends T>>> next,
Action0 onUnsubscribe)
Generates a synchronous
AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers. |
Copyright © 2018. All rights reserved.