Package | Description |
---|---|
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 <T0,T1,T2> FuncN<Void> |
Functions.fromAction(Action3<? super T0,? super T1,? super T2> f)
|
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 <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action3<? super S,Long,? super Observer<Observable<? extends T>>> next)
Generates a synchronous
AsyncOnSubscribe that calls the provided next
function to generate data to downstream subscribers. |
static <S,T> AsyncOnSubscribe<S,T> |
AsyncOnSubscribe.createSingleState(Func0<? extends S> generator,
Action3<? super S,Long,? super Observer<Observable<? extends T>>> 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.