Welcome to mirror list, hosted at ThFree Co, Russian Federation.

github.com/nodejs/node.git - Unnamed repository; edit this file 'description' to name the repository.
summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAnna Henningsen <anna@addaleax.net>2019-02-01 02:18:51 +0300
committerAnna Henningsen <anna@addaleax.net>2020-05-20 13:37:25 +0300
commitd2a6f06dce724d24b0aa3c7a2821e4757002bffc (patch)
tree6d91f468eaa1c4226de4f0340386b621846e6a4b /lib/internal/worker
parent6961c7f804cad26b471d5f7c4c92b0861ba19f12 (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.js7
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();
}