diff options
author | Michaël Zasso <targos@protonmail.com> | 2018-06-24 21:53:34 +0200 |
---|---|---|
committer | Michaël Zasso <targos@protonmail.com> | 2018-06-30 18:25:34 +0200 |
commit | b87b16456535743db5ecb93478f7b871f0f000a1 (patch) | |
tree | ba02c9e05cfd93f7ba99a7c1859ee600c84ad141 /test/parallel/test-worker-message-port-message-port-transferring.js | |
parent | 64a3fadf7192485197b9695b7bb2165c7e7d762d (diff) | |
download | android-node-v8-b87b16456535743db5ecb93478f7b871f0f000a1.tar.gz android-node-v8-b87b16456535743db5ecb93478f7b871f0f000a1.tar.bz2 android-node-v8-b87b16456535743db5ecb93478f7b871f0f000a1.zip |
test: add worker prefix to test-message* tests
It makes it easier to locate all tests related to the worker subsystem.
PR-URL: https://github.com/nodejs/node/pull/21512
Reviewed-By: Luigi Pinca <luigipinca@gmail.com>
Reviewed-By: James M Snell <jasnell@gmail.com>
Reviewed-By: Colin Ihrig <cjihrig@gmail.com>
Reviewed-By: Tiancheng "Timothy" Gu <timothygu99@gmail.com>
Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com>
Reviewed-By: Minwoo Jung <minwoo@nodesource.com>
Reviewed-By: Yuta Hiroto <hello@hiroppy.me>
Diffstat (limited to 'test/parallel/test-worker-message-port-message-port-transferring.js')
-rw-r--r-- | test/parallel/test-worker-message-port-message-port-transferring.js | 23 |
1 files changed, 23 insertions, 0 deletions
diff --git a/test/parallel/test-worker-message-port-message-port-transferring.js b/test/parallel/test-worker-message-port-message-port-transferring.js new file mode 100644 index 0000000000..32d997b9dd --- /dev/null +++ b/test/parallel/test-worker-message-port-message-port-transferring.js @@ -0,0 +1,23 @@ +// Flags: --experimental-worker +'use strict'; +const common = require('../common'); +const assert = require('assert'); + +const { MessageChannel } = require('worker_threads'); + +{ + const { port1: basePort1, port2: basePort2 } = new MessageChannel(); + const { + port1: transferredPort1, port2: transferredPort2 + } = new MessageChannel(); + + basePort1.postMessage({ transferredPort1 }, [ transferredPort1 ]); + basePort2.on('message', common.mustCall(({ transferredPort1 }) => { + transferredPort1.postMessage('foobar'); + transferredPort2.on('message', common.mustCall((msg) => { + assert.strictEqual(msg, 'foobar'); + transferredPort1.close(common.mustCall()); + basePort1.close(common.mustCall()); + })); + })); +} |