X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=6e234e2ea3dab6f045bfbfca84f7556afbff9f3c;hb=192566ec60b064afa6f1377fbf667152d93d5fe6;hp=9acfd6400ef59a12823b52899ca7f35e2ae96e56;hpb=facb41d7d33bd6c11970da5e946c51347824fd54;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 9acfd640..6e234e2e 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -62,7 +62,7 @@ export class FixedThreadPool< // FIXME: wait for tasks to be finished const workerNode = this.workerNodes[workerNodeKey] const worker = workerNode.worker - const waitWorkerExit = new Promise((resolve) => { + const waitWorkerExit = new Promise(resolve => { worker.on('exit', () => { resolve() }) @@ -82,7 +82,7 @@ export class FixedThreadPool< message: MessageValue, transferList?: TransferListItem[] ): void { - ;( + ( this.workerNodes[workerNodeKey].messageChannel as MessageChannel ).port1.postMessage(message, transferList) } @@ -108,7 +108,7 @@ export class FixedThreadPool< workerNodeKey: number, listener: (message: MessageValue) => void ): void { - ;( + ( this.workerNodes[workerNodeKey].messageChannel as MessageChannel ).port1.on('message', listener) }