rx.internal.operators

Class OperatorZip<R>

  • Type Parameters:
    R - the result type
    All Implemented Interfaces:
    Func1<Subscriber<? super R>,Subscriber<? super Observable<?>[]>>, Function, Observable.Operator<R,Observable<?>[]> 

    public final class OperatorZip<R>
extends Object
implements Observable.Operator<R,Observable<?>[]>
    Returns an Observable that emits the results of a function applied to sets of items emitted, in sequence, by two or more other Observables.

    The zip operation applies this function in strict sequence, so the first item emitted by the new Observable will be the result of the function applied to the first item emitted by each zipped Observable; the second item emitted by the new Observable will be the result of the function applied to the second item emitted by each zipped Observable; and so forth.

    The resulting Observable returned from zip will invoke onNext as many times as the number of onNext invocations of the source Observable that emits the fewest items.

    • Constructor Detail

      • OperatorZip

        public OperatorZip(FuncN<? extends R> f)

      • OperatorZip

        public OperatorZip(Func2 f)

      • OperatorZip

        public OperatorZip(Func3 f)

      • OperatorZip

        public OperatorZip(Func4 f)

      • OperatorZip

        public OperatorZip(Func5 f)

      • OperatorZip

        public OperatorZip(Func6 f)

      • OperatorZip

        public OperatorZip(Func7 f)

      • OperatorZip

        public OperatorZip(Func8 f)

      • OperatorZip

        public OperatorZip(Func9 f)