diff options
| -rw-r--r-- | lib/internal/worker/io.js | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/lib/internal/worker/io.js b/lib/internal/worker/io.js index d249ba8508..ad8056b5b9 100644 --- a/lib/internal/worker/io.js +++ b/lib/internal/worker/io.js @@ -62,7 +62,8 @@ MessagePort.prototype.unref = MessagePortPrototype.unref; // .onmessage events, and a function used for sending data to a MessagePort // in some other thread. MessagePort.prototype[kOnMessageListener] = function onmessage(payload) { - debug(`[${threadId}] received message`, payload); + if (payload.type !== messageTypes.STDIO_WANTS_MORE_DATA) + debug(`[${threadId}] received message`, payload); // Emit the deserialized object to userland. this.emit('message', payload); }; |