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 |
---|---|
static <T1,T2,T3,R> |
Observable.combineLatest(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> combineFunction)
Combines three 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.
|
<T1,T2,R> Observable<R> |
Observable.withLatestFrom(Observable<T1> o1,
Observable<T2> o2,
Func3<? super T,? super T1,? super T2,R> combiner)
Combines the value emission from this Observable with the latest emissions from the
other Observables via a function to produce the output item.
|
static <T1,T2,T3,R> |
Observable.zip(Observable<? extends T1> o1,
Observable<? extends T2> o2,
Observable<? extends T3> o3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of
three items emitted, in sequence, by three other Observables.
|
static <T1,T2,T3,R> |
Single.zip(Single<? extends T1> s1,
Single<? extends T2> s2,
Single<? extends T3> s3,
Func3<? super T1,? super T2,? super T3,? extends R> zipFunction)
Returns a Single that emits the results of a specified combiner function applied to three items emitted
by three other Singles.
|
Modifier and Type | Method and Description |
---|---|
static <T1,T2,T3> Func3<T1,T2,T3,Void> |
Actions.toFunc(Action3<T1,T2,T3> action)
Converts an
Action3 to a function that calls the action and returns null . |
static <T1,T2,T3,R> |
Actions.toFunc(Action3<T1,T2,T3> action,
R result)
Converts an
Action3 to a function that calls the action and returns a specified value. |
Modifier and Type | Method and Description |
---|---|
static <T0,T1,T2,R> |
Functions.fromFunc(Func3<? super T0,? super T1,? super T2,? extends R> f)
|
Modifier and Type | Method and Description |
---|---|
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createStateful(Func0<? extends S> generator,
Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next)
Generates a synchronous
AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers. |
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createStateful(Func0<? extends S> generator,
Func3<? super S,Long,? super Observer<Observable<? extends T>>,? extends S> next,
Action1<? super S> onUnsubscribe)
Generates a synchronous
AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers. |
Copyright © 2023. All rights reserved.