chore(node): add Readable.from utility

Added in v12.3.0 from PR nodejs/node#27660
imcotton · Jun 11, 2019 · 6739db8 · 6739db8
1 parent e94ce02
commit 6739db8
Show file tree

Hide file tree

Showing 2 changed files with 15 additions and 0 deletions.
diff --git a/types/node/stream.d.ts b/types/node/stream.d.ts
@@ -18,6 +18,7 @@ declare module "stream" {
         }
 
         class Readable extends Stream implements NodeJS.ReadableStream {
+            static from(iterable: Iterable<any> | AsyncIterable<any>, opts?: ReadableOptions): NodeJS.ReadableStream;
             readable: boolean;
             readonly readableHighWaterMark: number;
             readonly readableLength: number;

diff --git a/types/node/test/stream.ts b/types/node/test/stream.ts
@@ -192,3 +192,17 @@ function stream_readable_pipe_test() {
     z.close();
     rs.close();
 }
+
+async function readable_from() {
+    const list = [ 1, 2, 3 ];
+    const listPromise = list.map(n => Promise.resolve(n)));
+
+    const readableSync = Readable.from(list);
+    const readableAsync = Readable.from(listPromise);
+
+    let i = 0;
+    readableSync.on('data', n => assert(n === list[i++]));
+
+    let j = 0;
+    readableAsync.on('data', n => assert(n === list[j++]));
+}