Skip to content

Commit

Permalink
chore(node): add Readable.from utility
Browse files Browse the repository at this point in the history
Added in v12.3.0 from PR nodejs/node#27660
  • Loading branch information
imcotton committed Jun 11, 2019
1 parent e94ce02 commit 1c73ce9
Show file tree
Hide file tree
Showing 2 changed files with 23 additions and 0 deletions.
1 change: 1 addition & 0 deletions types/node/stream.d.ts
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Expand Down
22 changes: 22 additions & 0 deletions types/node/ts3.2/stream.ts
Original file line number Diff line number Diff line change
@@ -0,0 +1,22 @@
import { Readable } from "stream";
import { ok as assert } from 'assert';

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;

for await (const n of readableSync) {
assert(n === list[i++]);
}

i = 0;

for await (const n of readableAsync) {
assert(n === list[i++]);
}
}

0 comments on commit 1c73ce9

Please sign in to comment.