diff --git a/test/parallel/test-stream-pipeline.js b/test/parallel/test-stream-pipeline.js index 203a32b5cd74a1..5077aaa11a4e6b 100644 --- a/test/parallel/test-stream-pipeline.js +++ b/test/parallel/test-stream-pipeline.js @@ -1211,3 +1211,23 @@ const net = require('net'); d.write('test'); d.end(); } + +{ + 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'); + })); +}