chore(node): add Readable.from utility

imcotton · imcotton · commit 6739db866dad · 2019-06-11T18:34:26.000+08:00
Added in v12.3.0 from PR nodejs/node#27660
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++]));
+}

Original file line number	Diff line number	Diff line change
`@@ -18,6 +18,7 @@ declare module "stream" {`
`18`	`18`	`}`
`19`	`19`
`20`	`20`	`class Readable extends Stream implements NodeJS.ReadableStream {`
	`21`	`+ static from(iterable: Iterable<any> \| AsyncIterable<any>, opts?: ReadableOptions): NodeJS.ReadableStream;`
`21`	`22`	`readable: boolean;`
`22`	`23`	`readonly readableHighWaterMark: number;`
`23`	`24`	`readonly readableLength: number;`