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

    Methods in rx with parameters of type FuncN
    Modifier and Type
    Method
    Description
    static <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>
    Single.zip(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<Void>
    Functions.fromAction(Action0 f)
    Converts an Action0 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0> FuncN<Void>
    Functions.fromAction(Action1<? super T0> f)
    Converts an Action1 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, T1> FuncN<Void>
    Functions.fromAction(Action2<? super T0,? super T1> f)
    Converts an Action2 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, T1, T2>
    FuncN<Void>
    Functions.fromAction(Action3<? super T0,? super T1,? super T2> f)
    Converts an Action3 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <R> FuncN<R>
    Functions.fromFunc(Func0<? extends R> f)
    Converts a Func0 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, R> FuncN<R>
    Functions.fromFunc(Func1<? super T0,? extends R> f)
    Converts a Func1 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, T1, R>
    FuncN<R>
    Functions.fromFunc(Func2<? super T0,? super T1,? extends R> f)
    Converts a Func2 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, T1, T2, R>
    FuncN<R>
    Functions.fromFunc(Func3<? super T0,? super T1,? super T2,? extends R> f)
    Converts a Func3 to a FuncN to allow heterogeneous handling of functions with different arities.
    static <T0, T1, T2, T3, R>
    FuncN<R>
    Functions.fromFunc(Func4<? super T0,? super T1,? super T2,? super T3,? extends R> f)
    Converts a Func4 to a FuncN to allow heterogeneous handling of functions with different arities.
    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)
    Converts a Func5 to a FuncN to allow heterogeneous handling of functions with different arities.
    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)
    Converts a Func6 to a FuncN to allow heterogeneous handling of functions with different arities.
    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)
    Converts a Func7 to a FuncN to allow heterogeneous handling of functions with different arities.
    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)
    Converts a Func8 to a FuncN to allow heterogeneous handling of functions with different arities.
    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 a Func9 to a FuncN to allow heterogeneous handling of functions with different arities.
    static FuncN<Void>
    Actions.toFunc(ActionN action)
    Converts an ActionN to a function that calls the action and returns null.
    static <R> FuncN<R>
    Actions.toFunc(ActionN action, R result)
    Converts an ActionN 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) final FuncN<? extends R>
    OnSubscribeCombineLatest.combiner
     
    (package private) final FuncN<? extends R>
    OnSubscribeCombineLatest.LatestCoordinator.combiner
     
    (package private) final FuncN<R>
    OperatorWithLatestFromMany.combiner
     
    (package private) final FuncN<R>
    OperatorWithLatestFromMany.WithLatestMainSubscriber.combiner
     
    private final FuncN<? extends R>
    OperatorZip.Zip.zipFunction
     
    (package private) final 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
    Modifier
    Constructor
    Description
     
    LatestCoordinator(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)