1'use strict'; 2const common = require('../common'); 3const assert = require('assert'); 4 5const Readable = require('_stream_readable'); 6const EE = require('events').EventEmitter; 7 8class LegacyStream extends EE { 9 pause() {} 10 resume() {} 11} 12 13{ 14 const oldStream = new LegacyStream(); 15 const r = new Readable({ autoDestroy: true }) 16 .wrap(oldStream) 17 .on('error', common.mustCall(() => { 18 assert.strictEqual(r.destroyed, true); 19 })); 20 oldStream.emit('error', new Error()); 21} 22 23{ 24 const oldStream = new LegacyStream(); 25 const r = new Readable({ autoDestroy: false }) 26 .wrap(oldStream) 27 .on('error', common.mustCall(() => { 28 assert.strictEqual(r.destroyed, false); 29 })); 30 oldStream.emit('error', new Error()); 31} 32