diff options
author | Satya Rohith <me@satyarohith.com> | 2024-05-03 11:22:47 +0530 |
---|---|---|
committer | GitHub <noreply@github.com> | 2024-05-03 05:52:47 +0000 |
commit | 02d0ff58d2bab24ebbd1e61afe6b571ff4c415af (patch) | |
tree | 78b7fa4e7cf0265d688e34ddaa422ec344273e06 /tests/specs/node/worker_threads/message_port_transfer.mjs | |
parent | 3e98ea4e69732d8a659ca0ca61747fe3887ab673 (diff) |
refactor(tests): move worker_threads itests to spec tests (#23648)
Diffstat (limited to 'tests/specs/node/worker_threads/message_port_transfer.mjs')
-rw-r--r-- | tests/specs/node/worker_threads/message_port_transfer.mjs | 14 |
1 files changed, 14 insertions, 0 deletions
diff --git a/tests/specs/node/worker_threads/message_port_transfer.mjs b/tests/specs/node/worker_threads/message_port_transfer.mjs new file mode 100644 index 000000000..733a91c86 --- /dev/null +++ b/tests/specs/node/worker_threads/message_port_transfer.mjs @@ -0,0 +1,14 @@ +import { MessageChannel, Worker } from "node:worker_threads"; + +const { port1, port2 } = new MessageChannel(); +const worker = new Worker( + import.meta.resolve("./message_port_transfer1.mjs"), +); +// Send the port directly after the worker is created +worker.postMessage(port2, [port2]); +// Send a message to the worker using the transferred port +port1.postMessage("Hello from main thread!"); +worker.on("message", (message) => { + console.log("Received message from worker:", message); + worker.terminate(); +}); |