summaryrefslogtreecommitdiff
path: root/tests
diff options
context:
space:
mode:
authorSatya Rohith <me@satyarohith.com>2024-04-03 16:42:16 +0530
committerGitHub <noreply@github.com>2024-04-03 11:12:16 +0000
commit86bc7a43810846fc66bf06b7577490f01ead1918 (patch)
treeab0061bb1c35010363f36ebe86ea97e55f7c507b /tests
parent92a8ada7194ac013f8c34824f435f09b1f52ca5b (diff)
fix(ext/node): patch MessagePort if provided as workerData (#23198)
MessagePort if directly assigned to workerData property instead of embedding it in an object then it is not patched to a NodeMessagePort. This commit fixes the bug.
Diffstat (limited to 'tests')
-rw-r--r--tests/testdata/workers/node_worker_message_port.mjs2
-rw-r--r--tests/testdata/workers/node_worker_message_port_1.cjs2
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"));