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<?>[]>
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.
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescription(package private) static final class
(package private) static final class
(package private) final class
-
Field Summary
Fields -
Constructor Summary
ConstructorsConstructorDescriptionOperatorZip
(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
Modifier and TypeMethodDescriptionSubscriber
<? super Observable[]> call
(Subscriber<? super R> child)
-
Field Details
-
zipFunction
-
-
Constructor Details
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
OperatorZip
-
-
Method Details
-
call
- Specified by:
call
in interfaceFunc1<Subscriber<? super R>,
Subscriber<? super Observable<?>[]>>
-