diff options
author | Anna Henningsen <anna@addaleax.net> | 2019-02-01 02:18:51 +0300 |
---|---|---|
committer | Anna Henningsen <anna@addaleax.net> | 2020-05-20 13:37:25 +0300 |
commit | d2a6f06dce724d24b0aa3c7a2821e4757002bffc (patch) | |
tree | 6d91f468eaa1c4226de4f0340386b621846e6a4b /lib/internal/worker | |
parent | 6961c7f804cad26b471d5f7c4c92b0861ba19f12 (diff) |
worker: use _writev in internal communication
PR-URL: https://github.com/nodejs/node/pull/33454
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Benjamin Gruenbaum <benjamingr@gmail.com>
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Diffstat (limited to 'lib/internal/worker')
-rw-r--r-- | lib/internal/worker/io.js | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/lib/internal/worker/io.js b/lib/internal/worker/io.js index 1167198676b..0a97f17595f 100644 --- a/lib/internal/worker/io.js +++ b/lib/internal/worker/io.js @@ -206,12 +206,11 @@ class WritableWorkerStdio extends Writable { this[kWritableCallbacks] = []; } - _write(chunk, encoding, cb) { + _writev(chunks, cb) { this[kPort].postMessage({ type: messageTypes.STDIO_PAYLOAD, stream: this[kName], - chunk, - encoding + chunks: chunks.map(({ chunk, encoding }) => ({ chunk, encoding })) }); this[kWritableCallbacks].push(cb); if (this[kPort][kWaitingStreams]++ === 0) @@ -222,7 +221,7 @@ class WritableWorkerStdio extends Writable { this[kPort].postMessage({ type: messageTypes.STDIO_PAYLOAD, stream: this[kName], - chunk: null + chunks: [ { chunk: null, encoding: '' } ] }); cb(); } |