UNPKG

6 kBTypeScriptView Raw
1import { AsyncIterableX } from './asynciterablex';
2export declare class CombineLatestAsyncIterable<TSource> extends AsyncIterableX<TSource[]> {
3 private _sources;
4 constructor(sources: AsyncIterable<TSource>[]);
5 [Symbol.asyncIterator](signal?: AbortSignal): AsyncGenerator<TSource[], void, unknown>;
6}
7/**
8 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
9 * one of the async-iterable sequences produces an element.
10 *
11 * @export
12 * @template T The type of the elements in the first source sequence.
13 * @template T2 The type of the elements in the second source sequence.
14 * @param {AsyncIterable<T>} source First async-iterable source.
15 * @param {AsyncIterable<T2>} source2 Second async-iterable source.
16 * @returns {AsyncIterableX<[T, T2]>} An async-iterable sequence containing an array of all sources.
17 */
18export declare function combineLatest<T, T2>(source: AsyncIterable<T>, source2: AsyncIterable<T2>): AsyncIterableX<[T, T2]>;
19/**
20 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
21 * one of the async-iterable sequences produces an element.
22 *
23 * @export
24 * @template T The type of the elements in the first source sequence.
25 * @template T2 The type of the elements in the second source sequence.
26 * @template T3 The type of the elements in the third source sequence.
27 * @param {AsyncIterable<T>} source First async-iterable source.
28 * @param {AsyncIterable<T2>} source2 Second async-iterable source.
29 * @param {AsyncIterable<T3>} source3 Third async-iterable source.
30 * @returns {AsyncIterableX<[T, T2, T3]>} An async-iterable sequence containing an array of all sources.
31 */
32export declare function combineLatest<T, T2, T3>(source: AsyncIterable<T>, source2: AsyncIterable<T2>, source3: AsyncIterable<T3>): AsyncIterableX<[T, T2, T3]>;
33/**
34 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
35 * one of the async-iterable sequences produces an element.
36 *
37 * @export
38 * @template T The type of the elements in the first source sequence.
39 * @template T2 The type of the elements in the second source sequence.
40 * @template T3 The type of the elements in the third source sequence.
41 * @template T4 The type of the elements in the fourth source sequence.
42 * @param {AsyncIterable<T>} source First async-iterable source.
43 * @param {AsyncIterable<T2>} source2 Second async-iterable source.
44 * @param {AsyncIterable<T3>} source3 Third async-iterable source.
45 * @param {AsyncIterable<T4>} source4 Fourth async-iterable source.
46 * @returns {AsyncIterableX<[T, T2, T3, T4]>} An async-iterable sequence containing an array of all sources.
47 */
48export declare function combineLatest<T, T2, T3, T4>(source: AsyncIterable<T>, source2: AsyncIterable<T2>, source3: AsyncIterable<T3>, source4: AsyncIterable<T4>): AsyncIterableX<[T, T2, T3, T4]>;
49/**
50 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
51 * one of the async-iterable sequences produces an element.
52 *
53 * @export
54 * @template T The type of the elements in the first source sequence.
55 * @template T2 The type of the elements in the second source sequence.
56 * @template T3 The type of the elements in the third source sequence.
57 * @template T4 The type of the elements in the fourth source sequence.
58 * @template T5 The type of the elements in the fifth source sequence.
59 * @param {AsyncIterable<T>} source First async-iterable source.
60 * @param {AsyncIterable<T2>} source2 Second async-iterable source.
61 * @param {AsyncIterable<T3>} source3 Third async-iterable source.
62 * @param {AsyncIterable<T4>} source4 Fourth async-iterable source.
63 * @param {AsyncIterable<T5>} source5 Fifth async-iterable source.
64 * @returns {AsyncIterableX<[T, T2, T3, T4, T5]>} An async-iterable sequence containing an array of all sources.
65 */
66export declare function combineLatest<T, T2, T3, T4, T5>(source: AsyncIterable<T>, source2: AsyncIterable<T2>, source3: AsyncIterable<T3>, source4: AsyncIterable<T4>, source5: AsyncIterable<T5>): AsyncIterableX<[T, T2, T3, T4, T5]>;
67/**
68 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
69 * one of the async-iterable sequences produces an element.
70 *
71 * @export
72 * @template T The type of the elements in the first source sequence.
73 * @template T2 The type of the elements in the second source sequence.
74 * @template T3 The type of the elements in the third source sequence.
75 * @template T4 The type of the elements in the fourth source sequence.
76 * @template T5 The type of the elements in the fifth source sequence.
77 * @template T6 The type of the elements in the sixth source sequence.
78 * @param {AsyncIterable<T>} source First async-iterable source.
79 * @param {AsyncIterable<T2>} source2 Second async-iterable source.
80 * @param {AsyncIterable<T3>} source3 Third async-iterable source.
81 * @param {AsyncIterable<T4>} source4 Fourth async-iterable source.
82 * @param {AsyncIterable<T5>} source5 Fifth async-iterable source.
83 * @param {AsyncIterable<T6>} source6 Sixth async-iterable source.
84 * @returns {AsyncIterableX<[T, T2, T3, T4, T5, T6]>} An async-iterable sequence containing an array of all sources.
85 */
86export declare function combineLatest<T, T2, T3, T4, T5, T6>(source: AsyncIterable<T>, source2: AsyncIterable<T2>, source3: AsyncIterable<T3>, source4: AsyncIterable<T4>, source5: AsyncIterable<T5>, source6: AsyncIterable<T6>): AsyncIterableX<[T, T2, T3, T4, T5, T6]>;
87/**
88 * Merges multiple async-iterable sequences into one async-iterable sequence as an array whenever
89 * one of the async-iterable sequences produces an element.
90 *
91 * @export
92 * @template T The of the elements in the source sequences.
93 * @param {...AsyncIterable<T>[]} sources The async-iterable sources.
94 * @returns {AsyncIterableX<T[]>} An async-iterable sequence containing an array of all sources.
95 */
96export declare function combineLatest<T>(...sources: AsyncIterable<T>[]): AsyncIterableX<T[]>;