diff options
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/testdata/workers/node_worker_message_port.mjs | 2 | ||||
| -rw-r--r-- | tests/testdata/workers/node_worker_message_port_1.cjs | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/tests/testdata/workers/node_worker_message_port.mjs b/tests/testdata/workers/node_worker_message_port.mjs index 71640fb40..91c7e062d 100644 --- a/tests/testdata/workers/node_worker_message_port.mjs +++ b/tests/testdata/workers/node_worker_message_port.mjs @@ -9,7 +9,7 @@ const deferred = createDeferred(); const worker = new workerThreads.Worker( import.meta.resolve("./node_worker_message_port_1.cjs"), { - workerData: { workerPort }, + workerData: workerPort, transferList: [workerPort], }, ); diff --git a/tests/testdata/workers/node_worker_message_port_1.cjs b/tests/testdata/workers/node_worker_message_port_1.cjs index 01739c51e..3f78cd539 100644 --- a/tests/testdata/workers/node_worker_message_port_1.cjs +++ b/tests/testdata/workers/node_worker_message_port_1.cjs @@ -1,7 +1,7 @@ const { parentPort, workerData } = require("worker_threads"); parentPort.on("message", (msg) => { - const workerPort = workerData.workerPort; + const workerPort = workerData; parentPort.postMessage("Hello from worker on parentPort!"); workerPort.postMessage("Hello from worker on workerPort!"); workerPort.on("close", () => console.log("worker port closed")); |