We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent af3dffd commit ccf6405Copy full SHA for ccf6405
registry/lib/streams.d.ts
@@ -1,9 +1,13 @@
1
-declare type AnyIterable<T> = Iterable<T> | AsyncIterable<T>
+/// <reference types="node" />
2
+declare type AnyIterable<T> =
3
+ | Iterable<T>
4
+ | AsyncIterable<T>
5
+ | NodeJS.ReadableStream
6
declare const Streams: {
7
parallelForEach<T>(
8
concurrency: number,
9
func: (data: T) => Promise<void>,
- iterable: AsyncIterable<T>
10
+ iterable: AnyIterable<T>
11
): Promise<void>
12
parallelMap<T, R>(
13
concurrency: number
0 commit comments