%PDF- <> %âãÏÓ endobj 2 0 obj <> endobj 3 0 obj <>/ExtGState<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI] >>/Annots[ 28 0 R 29 0 R] /MediaBox[ 0 0 595.5 842.25] /Contents 4 0 R/Group<>/Tabs/S>> endobj ºaâÚÎΞ-ÌE1ÍØÄ÷{òò2ÿ ÛÖ^ÔÀá TÎ{¦?§®¥kuµùÕ5sLOšuY>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<>endobj 2 0 obj<> endobj 2 0 obj<>endobj 2 0 obj<>es 3 0 R>> endobj 2 0 obj<> ox[ 0.000000 0.000000 609.600000 935.600000]/Fi endobj 3 0 obj<> endobj 7 1 obj<>/ProcSet[/PDF/Text/ImageB/ImageC/ImageI]>>/Subtype/Form>> stream
'use strict'; const common = require('../common'); // Tests for the regression in _stream_writable discussed in // https://github.com/nodejs/node/pull/31756 // Specifically, when a write callback is invoked synchronously // with an error, and autoDestroy is not being used, the error // should still be emitted on nextTick. const { Writable } = require('stream'); class MyStream extends Writable { #cb = undefined; constructor() { super({ autoDestroy: false }); } _write(_, __, cb) { this.#cb = cb; } close() { // Synchronously invoke the callback with an error. this.#cb(new Error('foo')); } } const stream = new MyStream(); const mustError = common.mustCall(2); stream.write('test', () => {}); // Both error callbacks should be invoked. stream.on('error', mustError); stream.close(); // Without the fix in #31756, the error handler // added after the call to close will not be invoked. stream.on('error', mustError);