summaryrefslogtreecommitdiff
path: root/tests/unit_node/worker_threads_test.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tests/unit_node/worker_threads_test.ts')
-rw-r--r--tests/unit_node/worker_threads_test.ts26
1 files changed, 26 insertions, 0 deletions
diff --git a/tests/unit_node/worker_threads_test.ts b/tests/unit_node/worker_threads_test.ts
index 21bbca194..a96896ce5 100644
--- a/tests/unit_node/worker_threads_test.ts
+++ b/tests/unit_node/worker_threads_test.ts
@@ -460,3 +460,29 @@ Deno.test("[node/worker_threads] receiveMessageOnPort works if there's pending r
port5.close();
port6.close();
});
+
+Deno.test({
+ name: "[node/worker_threads] Worker env",
+ async fn() {
+ const deferred = Promise.withResolvers<void>();
+ const worker = new workerThreads.Worker(
+ `
+ import { parentPort } from "node:worker_threads";
+ import process from "node:process";
+ parentPort.postMessage(process.env.TEST_ENV);
+ `,
+ {
+ eval: true,
+ env: { TEST_ENV: "test" },
+ },
+ );
+
+ worker.on("message", (data) => {
+ assertEquals(data, "test");
+ deferred.resolve();
+ });
+
+ await deferred.promise;
+ await worker.terminate();
+ },
+});