1'use strict'; 2 3const common = require('../common'); 4const { pipeline, Duplex, PassThrough } = require('stream'); 5const assert = require('assert'); 6 7const remote = new PassThrough(); 8const local = new Duplex({ 9 read() {}, 10 write(chunk, enc, callback) { 11 callback(); 12 } 13}); 14 15pipeline(remote, local, remote, common.mustCall((err) => { 16 assert.strictEqual(err.code, 'ERR_STREAM_PREMATURE_CLOSE'); 17})); 18 19setImmediate(() => { 20 remote.end(); 21}); 22