Uses of Interface
rx.functions.FuncN
Packages that use FuncN
Package
Description
Base reactive classes: Observable, Single and Completable; base reactive consumers;
other common base interfaces.
Functional interfaces of functions and actions of arity 0 to 9 and related
utility classes.
Operators that allow composing Observables to transform and
manipulate data in an asynchronous, functional and thread-safe manner.
-
Uses of FuncN in rx
Modifier and TypeMethodDescriptionstatic <T,
R> Observable <R> Observable.combineLatest
(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
(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
(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.final <R> Observable
<R> Observable.withLatestFrom
(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.final <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
(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> 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 FuncNModifier and TypeMethodDescriptionFunctions.fromAction
(Action0 f) Functions.fromAction
(Action1<? super T0> f) Functions.fromAction
(Action2<? super T0, ? super T1> f) Functions.fromAction
(Action3<? super T0, ? super T1, ? super T2> f) static <R> FuncN
<R> static <T0,
R> FuncN <R> static <T0,
T1, R>
FuncN<R> static <T0,
T1, T2, R>
FuncN<R> static <T0,
T1, T2, T3, R>
FuncN<R> static <T0,
T1, T2, T3, T4, R>
FuncN<R> 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) Converts anActionN
to a function that calls the action and returnsnull
.static <R> FuncN
<R> 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 FuncNModifier and TypeFieldDescriptionOnSubscribeCombineLatest.combiner
OnSubscribeCombineLatest.LatestCoordinator.combiner
OperatorWithLatestFromMany.combiner
OperatorWithLatestFromMany.WithLatestMainSubscriber.combiner
OperatorZip.Zip.zipFunction
OperatorZip.zipFunction
Methods in rx.internal.operators with parameters of type FuncNConstructors in rx.internal.operators with parameters of type FuncNModifierConstructorDescriptionLatestCoordinator
(Subscriber<? super R> actual, FuncN<? extends R> combiner, int count, int bufferSize, boolean delayError) OnSubscribeCombineLatest
(Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner) OnSubscribeCombineLatest
(Observable<? extends T>[] sources, Iterable<? extends Observable<? extends T>> sourcesIterable, FuncN<? extends R> combiner, int bufferSize, boolean delayError) OperatorWithLatestFromMany
(Observable<T> main, Observable<?>[] others, 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)