File tree Expand file tree Collapse file tree 3 files changed +18
-0
lines changed
Expand file tree Collapse file tree 3 files changed +18
-0
lines changed Original file line number Diff line number Diff line change 1+ /// <reference lib="esnext.asynciterable" />
2+
13declare module "stream" {
24 import * as events from "events" ;
35
@@ -18,6 +20,7 @@ declare module "stream" {
1820 }
1921
2022 class Readable extends Stream implements NodeJS . ReadableStream {
23+ static from ( iterable : Iterable < any > | AsyncIterable < any > , opts ?: ReadableOptions ) : NodeJS . ReadableStream ;
2124 readable : boolean ;
2225 readonly readableHighWaterMark : number ;
2326 readonly readableLength : number ;
Original file line number Diff line number Diff line change @@ -192,3 +192,17 @@ function stream_readable_pipe_test() {
192192 z . close ( ) ;
193193 rs . close ( ) ;
194194}
195+
196+ async function readable_from ( ) {
197+ const list = [ 1 , 2 , 3 ] ;
198+ const listPromise = list . map ( n => Promise . resolve ( n ) ) ;
199+
200+ const readableSync = Readable . from ( list ) ;
201+ const readableAsync = Readable . from ( listPromise ) ;
202+
203+ let i = 0 ;
204+ readableSync . on ( 'data' , n => assert ( n === list [ i ++ ] ) ) ;
205+
206+ let j = 0 ;
207+ readableAsync . on ( 'data' , n => assert ( n === list [ j ++ ] ) ) ;
208+ }
Original file line number Diff line number Diff line change 11{
22 "private" : true ,
33 "dependencies" : {
4+ "@types/node" : " 10.x" ,
45 "safe-buffer" : " *"
56 }
67}
You can’t perform that action at this time.
0 commit comments