summaryrefslogtreecommitdiff
path: root/cli/tests/workers_test.ts
diff options
context:
space:
mode:
authorBartek IwaƄczuk <biwanczuk@gmail.com>2020-12-20 00:34:22 +0100
committerGitHub <noreply@github.com>2020-12-20 00:34:22 +0100
commite924bbdf3606e83ff9eef3a8ed640c4ecc34444f (patch)
tree19847fac129a678c1e5efa5f3495c8414146fa22 /cli/tests/workers_test.ts
parent660f75e066226a635375b70225df165bcf759077 (diff)
fix: TLA in web worker (#8809)
Implementors of `deno_core::JsRuntime` might want to do additional actions during each turn of event loop, eg. `deno_runtime::Worker` polls inspector, `deno_runtime::WebWorker` receives/dispatches messages from/to worker host. Previously `JsRuntime::mod_evaluate` was implemented in such fashion that it only polled `JsRuntime`'s event loop. This behavior turned out to be wrong in the example of `WebWorker` which couldn't receive/dispatch messages because its implementation of event loop was never called. This commit rewrites "mod_evaluate" to return a handle to receiver that resolves when module's promise resolves. It is now implementors responsibility to poll event loop after calling `mod_evaluate`.
Diffstat (limited to 'cli/tests/workers_test.ts')
-rw-r--r--cli/tests/workers_test.ts19
1 files changed, 19 insertions, 0 deletions
diff --git a/cli/tests/workers_test.ts b/cli/tests/workers_test.ts
index d907c97a9..4f7682be2 100644
--- a/cli/tests/workers_test.ts
+++ b/cli/tests/workers_test.ts
@@ -357,3 +357,22 @@ Deno.test({
w.terminate();
},
});
+
+Deno.test({
+ name: "Worker with top-level-await",
+ fn: async function (): Promise<void> {
+ const promise = deferred();
+ const worker = new Worker(
+ new URL("./worker_with_top_level_await.ts", import.meta.url).href,
+ { deno: true, type: "module" },
+ );
+ worker.onmessage = (e): void => {
+ console.log("received from worker", e.data);
+ worker.postMessage("from main");
+ promise.resolve();
+ };
+
+ await promise;
+ worker.terminate();
+ },
+});