summaryrefslogtreecommitdiff
path: root/cli/tests/workers
diff options
context:
space:
mode:
Diffstat (limited to 'cli/tests/workers')
-rw-r--r--cli/tests/workers/bench_large_message.ts2
-rw-r--r--cli/tests/workers/bench_round_robin.ts10
-rw-r--r--cli/tests/workers/bench_startup.ts10
-rw-r--r--cli/tests/workers/bench_worker.ts2
-rw-r--r--cli/tests/workers/deno_worker.ts2
-rw-r--r--cli/tests/workers/test.ts98
-rw-r--r--cli/tests/workers/test_worker.ts2
-rw-r--r--cli/tests/workers/worker_globals.ts2
-rw-r--r--cli/tests/workers/worker_location.ts2
-rw-r--r--cli/tests/workers/worker_with_top_level_await.ts2
10 files changed, 66 insertions, 66 deletions
diff --git a/cli/tests/workers/bench_large_message.ts b/cli/tests/workers/bench_large_message.ts
index 7f6cb26ce..a89ea9a78 100644
--- a/cli/tests/workers/bench_large_message.ts
+++ b/cli/tests/workers/bench_large_message.ts
@@ -7,7 +7,7 @@ function oneWorker(i: number) {
new URL("worker_large_message.js", import.meta.url).href,
{ type: "module" },
);
- worker.onmessage = (_e): void => {
+ worker.onmessage = (_e) => {
if (countDown > 0) {
countDown--;
return;
diff --git a/cli/tests/workers/bench_round_robin.ts b/cli/tests/workers/bench_round_robin.ts
index 7974760af..a39f7ec6f 100644
--- a/cli/tests/workers/bench_round_robin.ts
+++ b/cli/tests/workers/bench_round_robin.ts
@@ -10,7 +10,7 @@ import { Deferred, deferred } from "../../../test_util/std/async/deferred.ts";
function handleAsyncMsgFromWorker(
promiseTable: Map<number, Deferred<string>>,
msg: { cmdId: number; data: string },
-): void {
+) {
const promise = promiseTable.get(msg.cmdId);
if (promise === null) {
throw new Error(`Failed to find promise: cmdId: ${msg.cmdId}, msg: ${msg}`);
@@ -18,7 +18,7 @@ function handleAsyncMsgFromWorker(
promise?.resolve(data);
}
-async function main(): Promise<void> {
+async function main() {
const workers: Array<[Map<number, Deferred<string>>, Worker]> = [];
for (let i = 1; i <= workerCount; ++i) {
const worker = new Worker(
@@ -26,7 +26,7 @@ async function main(): Promise<void> {
{ type: "module" },
);
const promise = deferred();
- worker.onmessage = (e): void => {
+ worker.onmessage = (e) => {
if (e.data.cmdId === 0) promise.resolve();
};
worker.postMessage({ cmdId: 0, action: 2 });
@@ -35,7 +35,7 @@ async function main(): Promise<void> {
}
// assign callback function
for (const [promiseTable, worker] of workers) {
- worker.onmessage = (e): void => {
+ worker.onmessage = (e) => {
handleAsyncMsgFromWorker(promiseTable, e.data);
};
}
@@ -53,7 +53,7 @@ async function main(): Promise<void> {
}
for (const [, worker] of workers) {
const promise = deferred();
- worker.onmessage = (e): void => {
+ worker.onmessage = (e) => {
if (e.data.cmdId === 3) promise.resolve();
};
worker.postMessage({ action: 3 });
diff --git a/cli/tests/workers/bench_startup.ts b/cli/tests/workers/bench_startup.ts
index 5fbf23b45..bcf21ef44 100644
--- a/cli/tests/workers/bench_startup.ts
+++ b/cli/tests/workers/bench_startup.ts
@@ -1,15 +1,15 @@
// Benchmark measures time it takes to start and stop a number of workers.
const workerCount = 50;
-async function bench(): Promise<void> {
+async function bench() {
const workers: Worker[] = [];
for (let i = 1; i <= workerCount; ++i) {
const worker = new Worker(
new URL("bench_worker.ts", import.meta.url).href,
{ type: "module" },
);
- const promise = new Promise<void>((resolve): void => {
- worker.onmessage = (e): void => {
+ const promise = new Promise<void>((resolve) => {
+ worker.onmessage = (e) => {
if (e.data.cmdId === 0) resolve();
};
});
@@ -19,8 +19,8 @@ async function bench(): Promise<void> {
}
console.log("Done creating workers closing workers!");
for (const worker of workers) {
- const promise = new Promise<void>((resolve): void => {
- worker.onmessage = (e): void => {
+ const promise = new Promise<void>((resolve) => {
+ worker.onmessage = (e) => {
if (e.data.cmdId === 3) resolve();
};
});
diff --git a/cli/tests/workers/bench_worker.ts b/cli/tests/workers/bench_worker.ts
index 7e85eed03..1edd2750f 100644
--- a/cli/tests/workers/bench_worker.ts
+++ b/cli/tests/workers/bench_worker.ts
@@ -1,4 +1,4 @@
-onmessage = function (e): void {
+onmessage = function (e) {
const { cmdId, action, data } = e.data;
switch (action) {
case 0: // Static response
diff --git a/cli/tests/workers/deno_worker.ts b/cli/tests/workers/deno_worker.ts
index 6a57c47f0..2a29c8c4d 100644
--- a/cli/tests/workers/deno_worker.ts
+++ b/cli/tests/workers/deno_worker.ts
@@ -1,4 +1,4 @@
-onmessage = function (e): void {
+onmessage = function (e) {
if (typeof self.Deno === "undefined") {
throw new Error("Deno namespace not available in worker");
}
diff --git a/cli/tests/workers/test.ts b/cli/tests/workers/test.ts
index d62b644a4..44cbca0fe 100644
--- a/cli/tests/workers/test.ts
+++ b/cli/tests/workers/test.ts
@@ -12,7 +12,7 @@ import { fromFileUrl } from "../../../test_util/std/path/mod.ts";
Deno.test({
name: "worker terminate",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const jsWorker = new Worker(
@@ -24,17 +24,17 @@ Deno.test({
{ type: "module", name: "tsWorker" },
);
- tsWorker.onmessage = (e): void => {
+ tsWorker.onmessage = (e) => {
assertEquals(e.data, "Hello World");
promise.resolve();
};
- jsWorker.onmessage = (e): void => {
+ jsWorker.onmessage = (e) => {
assertEquals(e.data, "Hello World");
tsWorker.postMessage("Hello World");
};
- jsWorker.onerror = (e: Event): void => {
+ jsWorker.onerror = (e: Event) => {
e.preventDefault();
jsWorker.postMessage("Hello World");
};
@@ -55,7 +55,7 @@ Deno.test({
{ type: "module", name: "tsWorker" },
);
- tsWorker.onmessage = (e): void => {
+ tsWorker.onmessage = (e) => {
assertEquals(e.data, "Hello World");
promise.resolve();
};
@@ -69,7 +69,7 @@ Deno.test({
Deno.test({
name: "worker nested",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const nestedWorker = new Worker(
@@ -77,7 +77,7 @@ Deno.test({
{ type: "module", name: "nested" },
);
- nestedWorker.onmessage = (e): void => {
+ nestedWorker.onmessage = (e) => {
assert(e.data.type !== "error");
promise.resolve();
};
@@ -90,7 +90,7 @@ Deno.test({
Deno.test({
name: "worker throws when executing",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const throwingWorker = new Worker(
new URL("throwing_worker.js", import.meta.url).href,
@@ -98,7 +98,7 @@ Deno.test({
);
// deno-lint-ignore no-explicit-any
- throwingWorker.onerror = (e: any): void => {
+ throwingWorker.onerror = (e: any) => {
e.preventDefault();
assert(/Uncaught Error: Thrown error/.test(e.message));
promise.resolve();
@@ -111,14 +111,14 @@ Deno.test({
Deno.test({
name: "worker globals",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const workerOptions: WorkerOptions = { type: "module" };
const w = new Worker(
new URL("worker_globals.ts", import.meta.url).href,
workerOptions,
);
- w.onmessage = (e): void => {
+ w.onmessage = (e) => {
assertEquals(e.data, "true, true, true, true");
promise.resolve();
};
@@ -130,7 +130,7 @@ Deno.test({
Deno.test({
name: "worker fetch API",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const fetchingWorker = new Worker(
@@ -139,13 +139,13 @@ Deno.test({
);
// deno-lint-ignore no-explicit-any
- fetchingWorker.onerror = (e: any): void => {
+ fetchingWorker.onerror = (e: any) => {
e.preventDefault();
promise.reject(e.message);
};
// Defer promise.resolve() to allow worker to shut down
- fetchingWorker.onmessage = (e): void => {
+ fetchingWorker.onmessage = (e) => {
assert(e.data === "Done!");
promise.resolve();
};
@@ -157,7 +157,7 @@ Deno.test({
Deno.test({
name: "worker terminate busy loop",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const busyWorker = new Worker(
@@ -167,11 +167,11 @@ Deno.test({
let testResult = 0;
- busyWorker.onmessage = (e): void => {
+ busyWorker.onmessage = (e) => {
testResult = e.data;
if (testResult >= 10000) {
busyWorker.terminate();
- busyWorker.onmessage = (_e): void => {
+ busyWorker.onmessage = (_e) => {
throw new Error("unreachable");
};
setTimeout(() => {
@@ -188,7 +188,7 @@ Deno.test({
Deno.test({
name: "worker race condition",
- fn: async function (): Promise<void> {
+ fn: async function () {
// See issue for details
// https://github.com/denoland/deno/issues/4080
const promise = deferred();
@@ -198,7 +198,7 @@ Deno.test({
{ type: "module" },
);
- racyWorker.onmessage = (_e): void => {
+ racyWorker.onmessage = (_e) => {
setTimeout(() => {
promise.resolve();
}, 100);
@@ -211,7 +211,7 @@ Deno.test({
Deno.test({
name: "worker is event listener",
- fn: async function (): Promise<void> {
+ fn: async function () {
let messageHandlersCalled = 0;
let errorHandlersCalled = 0;
@@ -223,7 +223,7 @@ Deno.test({
{ type: "module" },
);
- worker.onmessage = (_e: Event): void => {
+ worker.onmessage = (_e: Event) => {
messageHandlersCalled++;
};
worker.addEventListener("message", (_e: Event) => {
@@ -234,7 +234,7 @@ Deno.test({
promise1.resolve();
});
- worker.onerror = (e): void => {
+ worker.onerror = (e) => {
errorHandlersCalled++;
e.preventDefault();
};
@@ -259,7 +259,7 @@ Deno.test({
Deno.test({
name: "worker scope is event listener",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise1 = deferred();
const worker = new Worker(
@@ -267,14 +267,14 @@ Deno.test({
{ type: "module" },
);
- worker.onmessage = (e: MessageEvent): void => {
+ worker.onmessage = (e: MessageEvent) => {
const { messageHandlersCalled, errorHandlersCalled } = e.data;
assertEquals(messageHandlersCalled, 4);
assertEquals(errorHandlersCalled, 4);
promise1.resolve();
};
- worker.onerror = (_e): void => {
+ worker.onerror = (_e) => {
throw new Error("unreachable");
};
@@ -287,7 +287,7 @@ Deno.test({
Deno.test({
name: "worker with Deno namespace",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const promise2 = deferred();
@@ -306,13 +306,13 @@ Deno.test({
},
);
- regularWorker.onmessage = (e): void => {
+ regularWorker.onmessage = (e) => {
assertEquals(e.data, "Hello World");
regularWorker.terminate();
promise.resolve();
};
- denoWorker.onmessage = (e): void => {
+ denoWorker.onmessage = (e) => {
assertEquals(e.data, "Hello World");
denoWorker.terminate();
promise2.resolve();
@@ -327,13 +327,13 @@ Deno.test({
Deno.test({
name: "worker with crypto in scope",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const w = new Worker(
new URL("worker_crypto.js", import.meta.url).href,
{ type: "module" },
);
- w.onmessage = (e): void => {
+ w.onmessage = (e) => {
assertEquals(e.data, true);
promise.resolve();
};
@@ -345,7 +345,7 @@ Deno.test({
Deno.test({
name: "Worker event handler order",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const w = new Worker(
new URL("test_worker.ts", import.meta.url).href,
@@ -353,7 +353,7 @@ Deno.test({
);
const arr: number[] = [];
w.addEventListener("message", () => arr.push(1));
- w.onmessage = (_e): void => {
+ w.onmessage = (_e) => {
arr.push(2);
};
w.addEventListener("message", () => arr.push(3));
@@ -369,7 +369,7 @@ Deno.test({
Deno.test({
name: "Worker immediate close",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const w = new Worker(
new URL("./immediately_close_worker.js", import.meta.url).href,
@@ -385,14 +385,14 @@ Deno.test({
Deno.test({
name: "Worker post undefined",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const worker = new Worker(
new URL("./post_undefined.ts", import.meta.url).href,
{ type: "module" },
);
- const handleWorkerMessage = (e: MessageEvent): void => {
+ const handleWorkerMessage = (e: MessageEvent) => {
console.log("main <- worker:", e.data);
worker.terminate();
promise.resolve();
@@ -650,12 +650,12 @@ Deno.test("Worker with disabled permissions", async function () {
Deno.test({
name: "worker location",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const workerModuleHref =
new URL("worker_location.ts", import.meta.url).href;
const w = new Worker(workerModuleHref, { type: "module" });
- w.onmessage = (e): void => {
+ w.onmessage = (e) => {
assertEquals(e.data, `${workerModuleHref}, true`);
promise.resolve();
};
@@ -667,14 +667,14 @@ Deno.test({
Deno.test({
name: "worker with relative specifier",
- fn: async function (): Promise<void> {
+ fn: async function () {
assertEquals(location.href, "http://127.0.0.1:4545/cli/tests/");
const promise = deferred();
const w = new Worker(
"./workers/test_worker.ts",
{ type: "module", name: "tsWorker" },
);
- w.onmessage = (e): void => {
+ w.onmessage = (e) => {
assertEquals(e.data, "Hello, world!");
promise.resolve();
};
@@ -686,13 +686,13 @@ Deno.test({
Deno.test({
name: "Worker with top-level-await",
- fn: async function (): Promise<void> {
+ fn: async function () {
const result = deferred();
const worker = new Worker(
new URL("worker_with_top_level_await.ts", import.meta.url).href,
{ type: "module" },
);
- worker.onmessage = (e): void => {
+ worker.onmessage = (e) => {
if (e.data == "ready") {
worker.postMessage("trigger worker handler");
} else if (e.data == "triggered worker handler") {
@@ -737,14 +737,14 @@ Deno.test({
Deno.test({
name: "structured cloning postMessage",
- fn: async function (): Promise<void> {
+ fn: async function () {
const result = deferred();
const worker = new Worker(
new URL("worker_structured_cloning.ts", import.meta.url).href,
{ type: "module" },
);
- worker.onmessage = (e): void => {
+ worker.onmessage = (e) => {
// self field should reference itself (circular ref)
const value = e.data.self.self.self;
@@ -772,14 +772,14 @@ Deno.test({
Deno.test({
name: "worker with relative specifier",
- fn: async function (): Promise<void> {
+ fn: async function () {
assertEquals(location.href, "http://127.0.0.1:4545/cli/tests/");
const promise = deferred();
const w = new Worker(
"./workers/test_worker.ts",
{ type: "module", name: "tsWorker" },
);
- w.onmessage = (e): void => {
+ w.onmessage = (e) => {
assertEquals(e.data, "Hello, world!");
promise.resolve();
};
@@ -791,7 +791,7 @@ Deno.test({
Deno.test({
name: "worker SharedArrayBuffer",
- fn: async function (): Promise<void> {
+ fn: async function () {
const promise = deferred();
const workerOptions: WorkerOptions = { type: "module" };
const w = new Worker(
@@ -804,9 +804,9 @@ Deno.test({
const bytes2 = new Uint8Array(sab2);
assertEquals(bytes1[0], 0);
assertEquals(bytes2[0], 0);
- w.onmessage = (): void => {
+ w.onmessage = () => {
w.postMessage([sab1, sab2]);
- w.onmessage = (): void => {
+ w.onmessage = () => {
assertEquals(bytes1[0], 1);
assertEquals(bytes2[0], 2);
promise.resolve();
@@ -819,7 +819,7 @@ Deno.test({
Deno.test({
name: "Send MessagePorts from / to workers",
- fn: async function (): Promise<void> {
+ fn: async function () {
const result = deferred();
const worker = new Worker(
new URL("message_port.ts", import.meta.url).href,
diff --git a/cli/tests/workers/test_worker.ts b/cli/tests/workers/test_worker.ts
index ca79dcfe4..996476058 100644
--- a/cli/tests/workers/test_worker.ts
+++ b/cli/tests/workers/test_worker.ts
@@ -2,7 +2,7 @@ if (self.name !== "tsWorker") {
throw Error(`Invalid worker name: ${self.name}, expected tsWorker`);
}
-onmessage = function (e): void {
+onmessage = function (e) {
postMessage(e.data);
close();
};
diff --git a/cli/tests/workers/worker_globals.ts b/cli/tests/workers/worker_globals.ts
index f26242306..90e369e41 100644
--- a/cli/tests/workers/worker_globals.ts
+++ b/cli/tests/workers/worker_globals.ts
@@ -1,4 +1,4 @@
-onmessage = function (): void {
+onmessage = function () {
postMessage(
[
self instanceof DedicatedWorkerGlobalScope,
diff --git a/cli/tests/workers/worker_location.ts b/cli/tests/workers/worker_location.ts
index 89fa83036..c3c1bb26f 100644
--- a/cli/tests/workers/worker_location.ts
+++ b/cli/tests/workers/worker_location.ts
@@ -1,4 +1,4 @@
-onmessage = function (): void {
+onmessage = function () {
postMessage(
`${location.href}, ${location instanceof WorkerLocation}`,
);
diff --git a/cli/tests/workers/worker_with_top_level_await.ts b/cli/tests/workers/worker_with_top_level_await.ts
index bc77c7932..1d20bb736 100644
--- a/cli/tests/workers/worker_with_top_level_await.ts
+++ b/cli/tests/workers/worker_with_top_level_await.ts
@@ -1,4 +1,4 @@
-function delay(ms: number): Promise<void> {
+function delay(ms: number) {
return new Promise<void>((resolve) => {
setTimeout(() => {
resolve();
generated by cgit v1.2.3 (git 2.25.1) at 2025-07-24 09:46:35 +0000