stream: do not defer construction by one microtick

lib/internal/streams/destroy.js

@@ -291,7 +291,7 @@ function constructNT(stream){
 }elseif(err){
 errorOrDestroy(stream,err,true);
 }else{
-process.nextTick(emitConstructNT,stream);
+stream.emit(kConstruct);
 }
 }
 
@@ -304,10 +304,6 @@ function constructNT(stream){
 }
 }
 
-functionemitConstructNT(stream){
-stream.emit(kConstruct);
-}
-
 functionisRequest(stream){
 returnstream?.setHeader&&typeofstream.abort==='function';
 }

test/parallel/test-fs-writestream-open-write.js

@@ -0,0 +1,28 @@
+'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);
+}));