stream: do not defer construction by one microtick · nodejs/node@270b519

} else if (err) {

errorOrDestroy(stream, err, true);

} else {

process.nextTick(emitConstructNT, stream);

stream.emit(kConstruct);

}

}

}

}

function emitConstructNT(stream) {

stream.emit(kConstruct);

}

function isRequest(stream) {

return stream?.setHeader && typeof stream.abort === 'function';

}

'use strict';

const common = require('../common');

const tmpdir = require('../common/tmpdir');

const { strictEqual } = require('assert');

const fs = require('fs');

// Regression test for https://github.com/nodejs/node/issues/51993

tmpdir.refresh();

const file = tmpdir.resolve('test-fs-writestream-open-write.txt');

const w = fs.createWriteStream(file);

w.on('open', common.mustCall(() => {

w.write('hello');

process.nextTick(() => {

w.write('world');

w.end();

});

}));

w.on('close', common.mustCall(() => {

strictEqual(fs.readFileSync(file, 'utf8'), 'helloworld');

fs.unlinkSync(file);

}));