diff --git a/test/parallel/test-stream-pipeline.js b/test/parallel/test-stream-pipeline.js index 27fff7756f5e16..be96891a18b0cc 100644 --- a/test/parallel/test-stream-pipeline.js +++ b/test/parallel/test-stream-pipeline.js @@ -518,3 +518,23 @@ const { promisify } = require('util'); }).on('error', common.mustNotCall()); }); } + +{ + const r = new Readable({ + read() {} + }); + r.push('hello'); + r.push('world'); + r.push(null); + let res = ''; + const w = new Writable({ + write(chunk, encoding, callback) { + res += chunk; + callback(); + } + }); + pipeline([r, w], common.mustCall((err) => { + assert.ok(!err); + assert.strictEqual(res, 'helloworld'); + })); +}