1berry/nodejs
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

test,worker: posting undefined/null message to message port

Browse Source 
Related: https://github.com/nodejs/node/issues/26122

PR-URL: https://github.com/nodejs/node/pull/26123
Reviewed-By: Anna Henningsen <anna@addaleax.net>
Reviewed-By: Denys Otrishko <shishugi@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
This commit is contained in:
legendecas 2019-02-15 16:14:11 +08:00 committed by Anna Henningsen
parent 70a500f3fd
commit c077c21ab8
No known key found for this signature in database
GPG Key ID: 9C63F3A6CD2AD8F9
1 changed files with 10 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
test/parallel/test-worker-onmessage.js
View File

@ -7,13 +7,20 @@ const { Worker, parentPort } = require('worker_threads');
if (!process.env.HAS_STARTED_WORKER) { if (!process.env.HAS_STARTED_WORKER) {
process.env.HAS_STARTED_WORKER = 1; process.env.HAS_STARTED_WORKER = 1;
const w = new Worker(__filename); const w = new Worker(__filename);
const expectation = [ 4, undefined, null ];
const actual = [];
w.on('message', common.mustCall((message) => { w.on('message', common.mustCall((message) => {
assert.strictEqual(message, 4); actual.push(message);
w.terminate(); if (actual.length === expectation.length) {
})); assert.deepStrictEqual(expectation, actual);
w.terminate();
}
}, expectation.length));
w.postMessage(2); w.postMessage(2);
} else { } else {
parentPort.onmessage = common.mustCall((message) => { parentPort.onmessage = common.mustCall((message) => {
parentPort.postMessage(message.data * 2); parentPort.postMessage(message.data * 2);
parentPort.postMessage(undefined);
parentPort.postMessage(null);
}); });
} }