summaryrefslogtreecommitdiff
path: root/tests/workers_round_robin_bench.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tests/workers_round_robin_bench.ts')
-rw-r--r--tests/workers_round_robin_bench.ts22
1 files changed, 13 insertions, 9 deletions
diff --git a/tests/workers_round_robin_bench.ts b/tests/workers_round_robin_bench.ts
index 818a1145f..d8bbbb2de 100644
--- a/tests/workers_round_robin_bench.ts
+++ b/tests/workers_round_robin_bench.ts
@@ -15,9 +15,11 @@ export type Resolvable<T> = Promise<T> & ResolvableMethods<T>;
export function createResolvable<T>(): Resolvable<T> {
let methods: ResolvableMethods<T>;
- const promise = new Promise<T>((resolve, reject) => {
- methods = { resolve, reject };
- });
+ const promise = new Promise<T>(
+ (resolve, reject): void => {
+ methods = { resolve, reject };
+ }
+ );
// TypeScript doesn't know that the Promise callback occurs synchronously
// therefore use of not null assertion (`!`)
return Object.assign(promise, methods!) as Resolvable<T>;
@@ -38,18 +40,20 @@ async function main(): Promise<void> {
const workers: Array<[Map<number, Resolvable<string>>, Worker]> = [];
for (var i = 1; i <= workerCount; ++i) {
const worker = new Worker("tests/subdir/bench_worker.ts");
- const promise = new Promise(resolve => {
- worker.onmessage = e => {
- if (e.data.cmdId === 0) resolve();
- };
- });
+ const promise = new Promise(
+ (resolve): void => {
+ worker.onmessage = (e): void => {
+ if (e.data.cmdId === 0) resolve();
+ };
+ }
+ );
worker.postMessage({ cmdId: 0, action: 2 });
await promise;
workers.push([new Map(), worker]);
}
// assign callback function
for (const [promiseTable, worker] of workers) {
- worker.onmessage = e => {
+ worker.onmessage = (e): void => {
handleAsyncMsgFromWorker(promiseTable, e.data);
};
}