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/testdata/workers/node_worker_message_port.mjs | |
| parent | 3e98ea4e69732d8a659ca0ca61747fe3887ab673 (diff) | |
refactor(tests): move worker_threads itests to spec tests (#23648)
Diffstat (limited to 'tests/testdata/workers/node_worker_message_port.mjs')
| -rw-r--r-- | tests/testdata/workers/node_worker_message_port.mjs | 41 |
1 files changed, 0 insertions, 41 deletions
diff --git a/tests/testdata/workers/node_worker_message_port.mjs b/tests/testdata/workers/node_worker_message_port.mjs deleted file mode 100644 index 91c7e062d..000000000 --- a/tests/testdata/workers/node_worker_message_port.mjs +++ /dev/null @@ -1,41 +0,0 @@ -import workerThreads from "node:worker_threads"; - -const { port1: mainPort, port2: workerPort } = new workerThreads - .MessageChannel(); - -// Note: not using Promise.withResolver() because it's not available in Node.js -const deferred = createDeferred(); - -const worker = new workerThreads.Worker( - import.meta.resolve("./node_worker_message_port_1.cjs"), - { - workerData: workerPort, - transferList: [workerPort], - }, -); - -worker.on("message", (data) => { - console.log("worker:", data); - mainPort.on("message", (msg) => { - console.log("mainPort:", msg); - deferred.resolve(); - }); - mainPort.on("close", (_msg) => { - console.log("mainPort closed"); - }); -}); - -worker.postMessage("Hello from parent"); -await deferred.promise; -await worker.terminate(); -mainPort.close(); - -function createDeferred() { - let resolveCallback; - let rejectCallback; - const promise = new Promise((resolve, reject) => { - resolveCallback = resolve; - rejectCallback = reject; - }); - return { promise, resolve: resolveCallback, reject: rejectCallback }; -} |
