diff options
Diffstat (limited to 'tests/unit_node/testdata/worker_threads2.mjs')
-rw-r--r-- | tests/unit_node/testdata/worker_threads2.mjs | 17 |
1 files changed, 17 insertions, 0 deletions
diff --git a/tests/unit_node/testdata/worker_threads2.mjs b/tests/unit_node/testdata/worker_threads2.mjs new file mode 100644 index 000000000..52d906bdf --- /dev/null +++ b/tests/unit_node/testdata/worker_threads2.mjs @@ -0,0 +1,17 @@ +// Copyright 2018-2023 the Deno authors. All rights reserved. MIT license. +import { parentPort, workerData } from "node:worker_threads"; +import { once } from "node:events"; + +async function message(expectedMessage) { + const [message] = await once(parentPort, "message"); + if (message !== expectedMessage) { + console.log(`Expected the message "${expectedMessage}", but got`, message); + // fail test + parentPort.close(); + } +} + +const uint = new Uint8Array(workerData.sharedArrayBuffer); +uint[0]++; +await message("Hello"); +parentPort.postMessage("Hello"); |