diff --git a/src/node/src/client.js b/src/node/src/client.js index f59ac5c94c5..8892aa7c50e 100644 --- a/src/node/src/client.js +++ b/src/node/src/client.js @@ -152,6 +152,7 @@ function _write(chunk, encoding, callback) { /* Once a write fails, just call the callback immediately to let the caller flush any pending writes. */ setImmediate(callback); + return; } try { message = this.serialize(chunk);