UNPKG

1.56 kBTypeScriptView Raw
1import { ObservableInputTuple, OperatorFunction, Cons } from '../types';
2/**
3 * Subscribes to the source, and the observable inputs provided as arguments, and combines their values, by index, into arrays.
4 *
5 * What is meant by "combine by index": The first value from each will be made into a single array, then emitted,
6 * then the second value from each will be combined into a single array and emitted, then the third value
7 * from each will be combined into a single array and emitted, and so on.
8 *
9 * This will continue until it is no longer able to combine values of the same index into an array.
10 *
11 * After the last value from any one completed source is emitted in an array, the resulting observable will complete,
12 * as there is no way to continue "zipping" values together by index.
13 *
14 * Use-cases for this operator are limited. There are memory concerns if one of the streams is emitting
15 * values at a much faster rate than the others. Usage should likely be limited to streams that emit
16 * at a similar pace, or finite streams of known length.
17 *
18 * In many cases, authors want `combineLatestWith` and not `zipWith`.
19 *
20 * @param otherInputs other observable inputs to collate values from.
21 * @return A function that returns an Observable that emits items by index
22 * combined from the source Observable and provided Observables, in form of an
23 * array.
24 */
25export declare function zipWith<T, A extends readonly unknown[]>(...otherInputs: [...ObservableInputTuple<A>]): OperatorFunction<T, Cons<T, A>>;
26//# sourceMappingURL=zipWith.d.ts.map
\No newline at end of file