nodejs
diff --git a/Collapse file
‎lib/internal/streams/writable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/writable.js
+2-1Lines changed: 2 additions & 1 deletion b/Collapse file
‎lib/internal/streams/writable.js‎
Copy file name to clipboardExpand all lines: lib/internal/streams/writable.js
+2-1Lines changed: 2 additions & 1 deletion
diff --git a/Collapse file
‎test/parallel/test-file-write-stream5.js‎
Copy file name to clipboard
+28Lines changed: 28 additions & 0 deletions b/Collapse file
‎test/parallel/test-file-write-stream5.js‎
Copy file name to clipboard
+28Lines changed: 28 additions & 0 deletions
@@ -733,7 +733,8 @@ function errorBuffer(state) {
 
 // If there's something in the buffer waiting, then process it.
 function clearBuffer(stream, state) {
-  if ((state[kState] & (kDestroyed | kBufferProcessing | kCorked | kBuffered)) !== kBuffered) {
+  if ((state[kState] & (kDestroyed | kBufferProcessing | kCorked | kBuffered | kConstructed)) !==
+      (kBuffered | kConstructed)) {
     return;
   }
 
 
@@ -0,0 +1,28 @@
+'use strict';
+
+// Test 'uncork' for WritableStream.
+// Refs: https://github.com/nodejs/node/issues/50979
+
+const common = require('../common');
+const fs = require('fs');
+const assert = require('assert');
+const test = require('node:test');
+const tmpdir = require('../common/tmpdir');
+
+const filepath = tmpdir.resolve('write_stream.txt');
+tmpdir.refresh();
+
+const data = 'data';
+
+test('writable stream uncork', () => {
+  const fileWriteStream = fs.createWriteStream(filepath);
+
+  fileWriteStream.on('finish', common.mustCall(() => {
+    const writtenData = fs.readFileSync(filepath, 'utf8');
+    assert.strictEqual(writtenData, data);
+  }));
+  fileWriteStream.cork();
+  fileWriteStream.write(data, common.mustCall());
+  fileWriteStream.uncork();
+  fileWriteStream.end();
+});
Original file line number	Diff line number	Diff line change
`@@ -733,7 +733,8 @@ function errorBuffer(state) {`
`733`	`733`
`734`	`734`	`// If there's something in the buffer waiting, then process it.`
`735`	`735`	`function clearBuffer(stream, state) {`
`736`		`- if ((state[kState] & (kDestroyed \| kBufferProcessing \| kCorked \| kBuffered)) !== kBuffered) {`
	`736`	`+ if ((state[kState] & (kDestroyed \| kBufferProcessing \| kCorked \| kBuffered \| kConstructed)) !==`
	`737`	`+ (kBuffered \| kConstructed)) {`
`737`	`738`	`return;`
`738`	`739`	`}`
`739`	`740`