@@ -1182,6 +1182,7 @@ making it possible to set up chains of piped streams:
1182
1182
1183
1183
``` js
1184
1184
const fs = require (' node:fs' );
1185
+ const zlib = require (' node:zlib' );
1185
1186
const r = fs .createReadStream (' file.txt' );
1186
1187
const z = zlib .createGzip ();
1187
1188
const w = fs .createWriteStream (' file.txt.gz' );
@@ -2316,6 +2317,7 @@ or has experienced an error or a premature close event.
2316
2317
2317
2318
``` js
2318
2319
const { finished } = require (' node:stream' );
2320
+ const fs = require (' node:fs' );
2319
2321
2320
2322
const rs = fs .createReadStream (' archive.tar' );
2321
2323
@@ -2338,6 +2340,7 @@ The `finished` API provides promise version:
2338
2340
2339
2341
``` js
2340
2342
const { finished } = require (' node:stream/promises' );
2343
+ const fs = require (' node:fs' );
2341
2344
2342
2345
const rs = fs .createReadStream (' archive.tar' );
2343
2346
@@ -2431,6 +2434,8 @@ receive an options argument as the last parameter with a
2431
2434
2432
2435
``` js
2433
2436
const { pipeline } = require (' node:stream/promises' );
2437
+ const fs = require (' node:fs' );
2438
+ const zlib = require (' node:zlib' );
2434
2439
2435
2440
async function run () {
2436
2441
await pipeline (
@@ -2449,6 +2454,8 @@ as the last argument:
2449
2454
2450
2455
``` js
2451
2456
const { pipeline } = require (' node:stream/promises' );
2457
+ const fs = require (' node:fs' );
2458
+ const zlib = require (' node:zlib' );
2452
2459
2453
2460
async function run () {
2454
2461
const ac = new AbortController ();
0 commit comments