nodejs
diff --git a/‎lib/internal/streams/destroy.js‎
Lines changed: 1 addition & 5 deletions b/‎lib/internal/streams/destroy.js‎
Lines changed: 1 addition & 5 deletions
diff --git a/‎test/parallel/test-fs-writestream-open-write.js‎
Lines changed: 28 additions & 0 deletions b/‎test/parallel/test-fs-writestream-open-write.js‎
Lines changed: 28 additions & 0 deletions
@@ -267,7 +267,7 @@ function constructNT(stream) {
     } else if (err) {
       errorOrDestroy(stream, err, true);
     } else {
-      process.nextTick(emitConstructNT, stream);
+      stream.emit(kConstruct);
     }
   }
 
@@ -280,10 +280,6 @@ function constructNT(stream) {
   }
 }
 
-function emitConstructNT(stream) {
-  stream.emit(kConstruct);
-}
-
 function isRequest(stream) {
   return stream?.setHeader && typeof stream.abort === 'function';
 }
 
@@ -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);
+}));
Original file line number	Diff line number	Diff line change
@@ -267,7 +267,7 @@ function constructNT(stream) {
267	267	} else if (err) {
268	268	errorOrDestroy(stream, err, true);
269	269	} else {
270		- process.nextTick(emitConstructNT, stream);
	270	+ stream.emit(kConstruct);
271	271	}
272	272	}
273	273
@@ -280,10 +280,6 @@ function constructNT(stream) {
280	280	}
281	281	}
282	282
283		- function emitConstructNT(stream) {
284		- stream.emit(kConstruct);
285		- }
286		-
287	283	function isRequest(stream) {
288	284	return stream?.setHeader && typeof stream.abort === 'function';
289	285	}