stream: propagate write error to end callback

Properly propagate all write errors throught to
end callback.

Fixes: nodejs#33684

lib/_stream_writable.js

@@ -56,6 +56,7 @@ const {
   ERR_STREAM_WRITE_AFTER_END,
   ERR_UNKNOWN_ENCODING
 } = require('internal/errors').codes;
+const { once } = require('internal/util');
 
 const { errorOrDestroy } = destroyImpl;
 
@@ -586,8 +587,17 @@ Writable.prototype.end = function(chunk, encoding, cb) {
     encoding = null;
   }
 
-  if (chunk !== null && chunk !== undefined)
-    this.write(chunk, encoding);
+  if (typeof cb === 'function') {
+    cb = once(cb);
+  }
+
+  if (chunk != null) {
+    this.write(chunk, encoding, cb ? function(err) {
+      if (err) {
+        cb(err);
+      }
+    } : null);
+  }
 
   // .end() fully uncorks.
   if (state.corked) {

test/parallel/test-stream-writable-end-cb-error.js

@@ -46,3 +46,23 @@ const stream = require('stream');
     writable.emit('error', new Error('kaboom'));
   }));
 }
+
+{
+  // Invoke end with write error
+  const writable = new stream.Writable();
+
+  writable._write = (chunk, encoding, cb) => {
+    process.nextTick(cb);
+  };
+  writable._final = (cb) => {
+    process.nextTick(cb);
+  };
+
+  writable.end();
+  writable.end('asd', common.mustCall((err) => {
+    assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END');
+  }));
+  writable.on('error', common.mustCall((err) => {
+    assert.strictEqual(err.code, 'ERR_STREAM_WRITE_AFTER_END');
+  }));
+}