tests/specs/node/worker_threads/message_port_transfer1.mjs


1
2
3
4
5
6
7
8
9
10

import { parentPort } from "node:worker_threads";

parentPort.on("message", (message) => {
  const transferredPort = message;
  transferredPort.on("message", (message) => {
    console.log("Received message from main thread:", message);
    parentPort.postMessage("Reply from worker");
  });
  console.log("Worker thread started!");
});