destroyed err

Author: atlowChemi

lib/internal/fs/streams.js

@@ -13,8 +13,9 @@ const {
 
 const {
   ERR_INVALID_ARG_TYPE,
-  ERR_OUT_OF_RANGE,
   ERR_METHOD_NOT_IMPLEMENTED,
+  ERR_OUT_OF_RANGE,
+  ERR_STREAM_DESTROYED,
   ERR_SYSTEM_ERROR,
 } = require('internal/errors').codes;
 const {
@@ -402,7 +403,7 @@ function writeAll(data, size, pos, cb, retries = 0) {
     }
 
     if (this.destroyed || er) {
-      return cb(er);
+      return cb(er || new ERR_STREAM_DESTROYED('write'));
     }
 
     this.bytesWritten += bytesWritten;
@@ -431,7 +432,7 @@ function writevAll(chunks, size, pos, cb, retries = 0) {
     }
 
     if (this.destroyed || er) {
-      return cb(er);
+      return cb(er || new ERR_STREAM_DESTROYED('writev'));
     }
 
     this.bytesWritten += bytesWritten;

test/parallel/test-fs-write-stream-eagain.mjs

@@ -29,4 +29,11 @@ describe('WriteStream EAGAIN', { concurrency: true }, () => {
     assert.strictEqual(mockWrite.mock.callCount(), 2);
     assert.strictEqual(fs.readFileSync(file, 'utf8'), 'foo');
   });
+
+  it('_write', async () => {
+    const stream = fs.createWriteStream(file);
+    mock.getter(stream, 'destroyed', () => true);
+    stream.end('foo');
+    await finished(stream).catch(common.mustCall());
+  });
 });