@@ -1215,6 +1215,7 @@ making it possible to set up chains of piped streams:
1215
1215
1216
1216
``` js
1217
1217
const fs = require (' node:fs' );
1218
+ const zlib = require (' node:zlib' );
1218
1219
const r = fs .createReadStream (' file.txt' );
1219
1220
const z = zlib .createGzip ();
1220
1221
const w = fs .createWriteStream (' file.txt.gz' );
@@ -2381,6 +2382,7 @@ or has experienced an error or a premature close event.
2381
2382
2382
2383
``` js
2383
2384
const { finished } = require (' node:stream' );
2385
+ const fs = require (' node:fs' );
2384
2386
2385
2387
const rs = fs .createReadStream (' archive.tar' );
2386
2388
@@ -2403,6 +2405,7 @@ The `finished` API provides promise version:
2403
2405
2404
2406
``` js
2405
2407
const { finished } = require (' node:stream/promises' );
2408
+ const fs = require (' node:fs' );
2406
2409
2407
2410
const rs = fs .createReadStream (' archive.tar' );
2408
2411
@@ -2501,6 +2504,8 @@ receive an options argument as the last parameter with a
2501
2504
2502
2505
``` js
2503
2506
const { pipeline } = require (' node:stream/promises' );
2507
+ const fs = require (' node:fs' );
2508
+ const zlib = require (' node:zlib' );
2504
2509
2505
2510
async function run () {
2506
2511
await pipeline (
@@ -2519,6 +2524,8 @@ as the last argument:
2519
2524
2520
2525
``` js
2521
2526
const { pipeline } = require (' node:stream/promises' );
2527
+ const fs = require (' node:fs' );
2528
+ const zlib = require (' node:zlib' );
2522
2529
2523
2530
async function run () {
2524
2531
const ac = new AbortController ();
0 commit comments