Class OperatorZip<R>

java.lang.Object
rx.internal.operators.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.

  • Field Details

    • zipFunction

      final FuncN<? extends R> zipFunction
  • Constructor Details

    • 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)
  • Method Details