stream: give error message if write() cb called twice

lib/_stream_writable.js

@@ -37,6 +37,7 @@ const { getHighWaterMark } = require('internal/streams/state');
 const {
   ERR_INVALID_ARG_TYPE,
   ERR_METHOD_NOT_IMPLEMENTED,
+  ERR_MULTIPLE_CALLBACK,
   ERR_STREAM_CANNOT_PIPE,
   ERR_STREAM_DESTROYED,
   ERR_STREAM_NULL_VALUES,
@@ -445,6 +446,9 @@ function onwrite(stream, er) {
   var sync = state.sync;
   var cb = state.writecb;
 
+  if (typeof cb !== 'function')
+    throw new ERR_MULTIPLE_CALLBACK();
+
   onwriteStateUpdate(state);
 
   if (er)

test/parallel/test-stream-writable-write-cb-twice.js

@@ -0,0 +1,49 @@
+'use strict';
+const common = require('../common');
+const { Writable } = require('stream');
+
+{
+  // Sync + Sync
+  const writable = new Writable({
+    write: common.mustCall((buf, enc, cb) => {
+      cb();
+      common.expectsError(cb, {
+        code: 'ERR_MULTIPLE_CALLBACK',
+        type: Error
+      });
+    })
+  });
+  writable.write('hi');
+}
+
+{
+  // Sync + Async
+  const writable = new Writable({
+    write: common.mustCall((buf, enc, cb) => {
+      cb();
+      process.nextTick(() => {
+        common.expectsError(cb, {
+          code: 'ERR_MULTIPLE_CALLBACK',
+          type: Error
+        });
+      });
+    })
+  });
+  writable.write('hi');
+}
+
+{
+  // Async + Async
+  const writable = new Writable({
+    write: common.mustCall((buf, enc, cb) => {
+      process.nextTick(cb);
+      process.nextTick(() => {
+        common.expectsError(cb, {
+          code: 'ERR_MULTIPLE_CALLBACK',
+          type: Error
+        });
+      });
+    })
+  });
+  writable.write('hi');
+}