diff options
Diffstat (limited to 'tests/workers_round_robin_bench.ts')
-rw-r--r-- | tests/workers_round_robin_bench.ts | 22 |
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); }; } |