X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=d22d75fb3b5a397e8a2371a700d53d4f243160ba;hb=b79570c2ee7d866b615889836c29ece32d559611;hp=9561cc787a2cddbcb757fa1939cdeea25888a5a0;hpb=799c9e089724b6402ae72e0a60719017055a6669;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 9561cc78..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, port: port2 - }, + } satisfies MessageValue, [port2] ) }