Uses of Interface
rx.functions.FuncN
-
Packages that use FuncN 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.internal.operators Operators that allow composing Observables to transform and manipulate data in an asynchronous, functional and thread-safe manner. -
-
Uses of FuncN in rx
Methods in rx with parameters of type FuncN Modifier and Type Method Description static <T,R>
Observable<R>Observable. combineLatest(java.lang.Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction)
Combines a collection 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 <T,R>
Observable<R>Observable. combineLatest(java.util.List<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction)
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 <T,R>
Observable<R>Observable. combineLatestDelayError(java.lang.Iterable<? extends Observable<? extends T>> sources, FuncN<? extends R> combineFunction)
Combines a collection 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 and delays any error from the sources until all source Observables terminate.<R> Observable<R>
Observable. withLatestFrom(java.lang.Iterable<Observable<?>> others, FuncN<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.<R> Observable<R>
Observable. withLatestFrom(Observable<?>[] others, FuncN<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 <R> Observable<R>
Observable. zip(java.lang.Iterable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction)
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<R>
Observable. zip(Observable<?>[] ws, FuncN<? extends R> zipFunction)
Returns an Observable that emits the results of a specified combiner function applied to combinations of items emitted, in sequence, by an array of other Observables.static <R> Observable<R>
Observable. zip(Observable<? extends Observable<?>> ws, FuncN<? extends R> zipFunction)
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.static <R> Single<R>
Single. zip(java.lang.Iterable<? extends Single<?>> singles, FuncN<? extends R> zipFunction)
Returns a Single that emits the result of specified combiner function applied to combination of items emitted, in sequence, by an Iterable of other Singles. -
Uses of FuncN in rx.functions
Methods in rx.functions that return FuncN Modifier and Type Method Description static FuncN<java.lang.Void>
Functions. fromAction(Action0 f)
static <T0> FuncN<java.lang.Void>
Functions. fromAction(Action1<? super T0> f)
static <T0,T1>
FuncN<java.lang.Void>Functions. fromAction(Action2<? super T0,? super T1> f)
static <T0,T1,T2>
FuncN<java.lang.Void>Functions. fromAction(Action3<? super T0,? super T1,? super T2> f)
static <R> FuncN<R>
Functions. fromFunc(Func0<? extends R> f)
static <T0,R>
FuncN<R>Functions. fromFunc(Func1<? super T0,? extends R> f)
static <T0,T1,R>
FuncN<R>Functions. fromFunc(Func2<? super T0,? super T1,? extends R> f)
static <T0,T1,T2,R>
FuncN<R>Functions. fromFunc(Func3<? super T0,? super T1,? super T2,? extends R> f)
static <T0,T1,T2,T3,R>
FuncN<R>Functions. fromFunc(Func4<? super T0,? super T1,? super T2,? super T3,? extends R> f)
static <T0,T1,T2,T3,T4,R>
FuncN<R>Functions. fromFunc(Func5<? super T0,? super T1,? super T2,? super T3,? super T4,? extends R> f)
static <T0,T1,T2,T3,T4,T5,R>
FuncN<R>Functions. fromFunc(Func6<? super T0,? super T1,? super T2,? super T3,? super T4,? super T5,? extends R> f)
static <T0,T1,T2,T3,T4,T5,T6,R>
FuncN<R>Functions. fromFunc(Func7<? super T0,? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? extends R> f)
static <T0,T1,T2,T3,T4,T5,T6,T7,R>
FuncN<R>Functions. fromFunc(Func8<? super T0,? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? extends R> f)
static <T0,T1,T2,T3,T4,T5,T6,T7,T8,R>
FuncN<R>Functions. fromFunc(Func9<? super T0,? super T1,? super T2,? super T3,? super T4,? super T5,? super T6,? super T7,? super T8,? extends R> f)
static FuncN<java.lang.Void>
Actions. toFunc(ActionN action)
Converts anActionN
to a function that calls the action and returnsnull
.static <R> FuncN<R>
Actions. toFunc(ActionN action, R result)
Converts anActionN
to a function that calls the action and returns a specified value. -
Uses of FuncN in rx.internal.operators
Fields in rx.internal.operators declared as FuncN Modifier and Type Field Description (package private) FuncN<? extends R>
OnSubscribeCombineLatest. combiner
(package private) FuncN<? extends R>
OnSubscribeCombineLatest.LatestCoordinator. combiner
(package private) FuncN<R>
OperatorWithLatestFromMany. combiner
(package private) FuncN<R>
OperatorWithLatestFromMany.WithLatestMainSubscriber. combiner
private FuncN<? extends R>
OperatorZip.Zip. zipFunction
(package private) FuncN<? extends R>
OperatorZip. zipFunction
Methods in rx.internal.operators with parameters of type FuncN Modifier and Type Method Description static <T,R>
Single<R>SingleOperatorZip. zip(Single<? extends T>[] singles, FuncN<? extends R> zipper)
Constructors in rx.internal.operators with parameters of type FuncN Constructor Description LatestCoordinator(Subscriber<? super R> actual, FuncN<? extends R> combiner, int count, int bufferSize, boolean delayError)
OnSubscribeCombineLatest(java.lang.Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner)
OnSubscribeCombineLatest(Observable<? extends T>[] sources, java.lang.Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError)
OperatorWithLatestFromMany(Observable<T> main, Observable<?>[] others, java.lang.Iterable<Observable<?>> othersIterable, FuncN<R> combiner)
OperatorZip(FuncN<? extends R> f)
WithLatestMainSubscriber(Subscriber<? super R> actual, FuncN<R> combiner, int n)
Zip(Subscriber<? super R> child, FuncN<? extends R> zipFunction)
-