Package rx.internal.operators
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 java.lang.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 ofonNext
invocations of the source Observable that emits the fewest items.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description (package private) static class
OperatorZip.Zip<R>
(package private) static class
OperatorZip.ZipProducer<R>
(package private) class
OperatorZip.ZipSubscriber
-
Field Summary
Fields Modifier and Type Field Description (package private) FuncN<? extends R>
zipFunction
-
Constructor Summary
Constructors Constructor Description OperatorZip(Func2 f)
OperatorZip(Func3 f)
OperatorZip(Func4 f)
OperatorZip(Func5 f)
OperatorZip(Func6 f)
OperatorZip(Func7 f)
OperatorZip(Func8 f)
OperatorZip(Func9 f)
OperatorZip(FuncN<? extends R> f)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Subscriber<? super Observable[]>
call(Subscriber<? super R> child)
-
-
-
Constructor Detail
-
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 Detail
-
call
public Subscriber<? super Observable[]> call(Subscriber<? super R> child)
- Specified by:
call
in interfaceFunc1<Subscriber<? super R>,Subscriber<? super Observable<?>[]>>
-
-