Commit 5469adf
test: test pipeline end on transform streams
Add test that confirms that
`stream.promises.pipeline(source, transform, dest, {end: false});`
only skips ending the destination stream.
`{end: false}` should still end any transform streams.
PR-URL: #48970
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>1 parent 04de576 commit 5469adf
1 file changed
Lines changed: 5 additions & 1 deletion
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -1476,10 +1476,14 @@ const tsp = require('timers/promises'); | |||
| 1476 | 1476 | }); | |
| 1477 | 1477 | ||
| 1478 | 1478 | const duplex = new PassThrough(); | |
| 1479 | + const transform = new PassThrough(); | ||
| 1479 | 1480 | ||
| 1480 | 1481 | read.push(null); | |
| 1481 | 1482 | ||
| 1482 | - await pipelinePromise(read, duplex, { end: false }); | ||
| 1483 | + await pipelinePromise(read, transform, duplex, { end: false }); | ||
| 1484 | + | ||
| 1485 | + assert.strictEqual(transform.destroyed, true); | ||
| 1486 | + assert.strictEqual(transform.writableEnded, true); | ||
| 1483 | 1487 | ||
| 1484 | 1488 | assert.strictEqual(duplex.destroyed, false); | |
| 1485 | 1489 | assert.strictEqual(duplex.writableEnded, false); | |
0 commit comments