X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=d22d75fb3b5a397e8a2371a700d53d4f243160ba;hb=19b53d08bec0e752fb3bdf054a0810db8bb8565d;hp=ff427ea228533096c5fd93a3b92ce59963ca86a0;hpb=c63a35a04c190989be80f9218d97e0aca739475e;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index ff427ea2..d22d75fb 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -1,5 +1,4 @@ import { - type MessagePort, type TransferListItem, type Worker, isMainThread @@ -54,7 +53,10 @@ export class FixedThreadPool< transferList?: TransferListItem[] ): void { this.workerNodes[workerNodeKey].messageChannel?.port1.postMessage( - { ...message, workerId: this.getWorkerInfo(workerNodeKey).id }, + { + ...message, + workerId: this.getWorkerInfo(workerNodeKey)?.id + } satisfies MessageValue, transferList ) } @@ -63,13 +65,13 @@ export class FixedThreadPool< protected sendStartupMessageToWorker (workerNodeKey: number): void { const workerNode = this.workerNodes[workerNodeKey] // eslint-disable-next-line @typescript-eslint/no-non-null-assertion - const port2: MessagePort = workerNode.messageChannel!.port2 + const port2 = workerNode.messageChannel!.port2 workerNode.worker.postMessage( { ready: false, - workerId: this.getWorkerInfo(workerNodeKey).id, + workerId: this.getWorkerInfo(workerNodeKey)?.id, port: port2 - }, + } satisfies MessageValue, [port2] ) }