UNPKG

5.98 kBTypeScriptView Raw
1import { AsyncIterableX } from './asynciterablex';
2export declare class MergeAsyncIterable<T> extends AsyncIterableX<T> {
3 private _source;
4 constructor(source: AsyncIterable<T>[]);
5 [Symbol.asyncIterator](signal?: AbortSignal): AsyncIterator<T>;
6}
7/**
8 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
9 *
10 * @export
11 * @template T The type of the first async-iterable sequence.
12 * @template T2 The type of the second async-iterable sequence.
13 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
14 * @param {AsyncIterable<T2>} v2 The second async-iterable source to merge.
15 * @returns {(AsyncIterableX<T | T2>)} The merged elements from all of the specified async-iterable sequences into a single async-iterable sequence.
16 */
17export declare function merge<T, T2>(source: AsyncIterable<T>, v2: AsyncIterable<T2>): AsyncIterableX<T | T2>;
18/**
19 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
20 *
21 * @export
22 * @template T The type of the first async-iterable sequence.
23 * @template T2 The type of the second async-iterable sequence.
24 * @template T3 The type of the third async-iterable sequence.
25 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
26 * @param {AsyncIterable<T2>} v2 The second async-iterable source to merge.
27 * @param {AsyncIterable<T3>} v3 The third async-iterable source to merge.
28 * @returns {(AsyncIterableX<T | T2 | T3>)} The merged elements from all of the specified async-iterable sequences
29 * into a single async-iterable sequence.
30 */
31export declare function merge<T, T2, T3>(source: AsyncIterable<T>, v2: AsyncIterable<T2>, v3: AsyncIterable<T3>): AsyncIterableX<T | T2 | T3>;
32/**
33 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
34 *
35 * @export
36 * @template T The type of the first async-iterable sequence.
37 * @template T2 The type of the second async-iterable sequence.
38 * @template T3 The type of the third async-iterable sequence.
39 * @template T4 The type of the fourth async-iterable sequence.
40 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
41 * @param {AsyncIterable<T2>} v2 The second async-iterable source to merge.
42 * @param {AsyncIterable<T3>} v3 The third async-iterable source to merge.
43 * @param {AsyncIterable<T4>} v4 The fourth async-iterable source to merge.
44 * @returns {(AsyncIterableX<T | T2 | T3 | T4>)} The merged elements from all of the specified async-iterable sequences
45 * into a single async-iterable sequence.
46 */
47export declare function merge<T, T2, T3, T4>(source: AsyncIterable<T>, v2: AsyncIterable<T2>, v3: AsyncIterable<T3>, v4: AsyncIterable<T4>): AsyncIterableX<T | T2 | T3 | T4>;
48/**
49 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
50 *
51 * @export
52 * @template T The type of the first async-iterable sequence.
53 * @template T2 The type of the second async-iterable sequence.
54 * @template T3 The type of the third async-iterable sequence.
55 * @template T4 The type of the fourth async-iterable sequence.
56 * @template T5 The type of the fifth async-iterable sequence.
57 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
58 * @param {AsyncIterable<T2>} v2 The second async-iterable source to merge.
59 * @param {AsyncIterable<T3>} v3 The third async-iterable source to merge.
60 * @param {AsyncIterable<T4>} v4 The fourth async-iterable source to merge.
61 * @param {AsyncIterable<T5>} v5 The fifth async-iterable source to merge.
62 * @returns {(AsyncIterable<T | T2 | T3 | T4 | T5>)} The merged elements from all of the specified async-iterable sequences
63 * into a single async-iterable sequence.
64 */
65export declare function merge<T, T2, T3, T4, T5>(source: AsyncIterable<T>, v2: AsyncIterable<T2>, v3: AsyncIterable<T3>, v4: AsyncIterable<T4>, v5: AsyncIterable<T5>): AsyncIterable<T | T2 | T3 | T4 | T5>;
66/**
67 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
68 *
69 * @export
70 * @template T The type of the first async-iterable sequence.
71 * @template T2 The type of the second async-iterable sequence.
72 * @template T3 The type of the third async-iterable sequence.
73 * @template T4 The type of the fourth async-iterable sequence.
74 * @template T5 The type of the fifth async-iterable sequence.
75 * @template T6 The type of the sixth async-iterable sequence.
76 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
77 * @param {AsyncIterable<T2>} v2 The second async-iterable source to merge.
78 * @param {AsyncIterable<T3>} v3 The third async-iterable source to merge.
79 * @param {AsyncIterable<T4>} v4 The fourth async-iterable source to merge.
80 * @param {AsyncIterable<T5>} v5 The fifth async-iterable source to merge.
81 * @param {AsyncIterable<T6>} v6 The sixth async-iterable source to merge.
82 * @returns {(AsyncIterable<T | T2 | T3 | T4 | T5 | T6>)} The merged elements from all of the specified async-iterable sequences
83 * into a single async-iterable sequence.
84 */
85export declare function merge<T, T2, T3, T4, T5, T6>(source: AsyncIterable<T>, v2: AsyncIterable<T2>, v3: AsyncIterable<T3>, v4: AsyncIterable<T4>, v5: AsyncIterable<T5>, v6: AsyncIterable<T6>): AsyncIterable<T | T2 | T3 | T4 | T5 | T6>;
86/**
87 * Merges elements from all of the specified async-iterable sequences into a single async-iterable sequence.
88 *
89 * @export
90 * @template T The type of the elements in the sequence to merge.
91 * @param {AsyncIterable<T>} source The first async-iterable source to merge.
92 * @param {...AsyncIterable<T>[]} args The async-iterable sources to merge.
93 * @returns {AsyncIterableX<T>} The merged elements from all of the specified async-iterable sequences into a single async-iterable sequence.
94 */
95export declare function merge<T>(source: AsyncIterable<T>, ...args: AsyncIterable<T>[]): AsyncIterableX<T>;