X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fthread%2Ffixed.ts;h=7753d1d60cb21910a5f871338889023ef4de12c1;hb=761b0c73be0bf581f50a78123913f933bd405f52;hp=764d5851d9be4d6cd9c52b2333b1348c50c803bf;hpb=14a2e530e555fa52f98454e182d0094e0ff5d86f;p=poolifier.git diff --git a/src/pools/thread/fixed.ts b/src/pools/thread/fixed.ts index 764d5851..7753d1d6 100644 --- a/src/pools/thread/fixed.ts +++ b/src/pools/thread/fixed.ts @@ -22,7 +22,7 @@ export type ThreadWorkerWithMessageChannel = Worker & Draft * This pool selects the threads in a round robin fashion. * * @typeParam Data - Type of data sent to the worker. This can only be serializable data. - * @typeParam Response - Type of response of execution. This can only be serializable data. + * @typeParam Response - Type of execution response. This can only be serializable data. * @author [Alessandro Pio Ardizio](https://github.com/pioardi) * @since 0.0.1 */ @@ -68,10 +68,10 @@ export class FixedThreadPool< /** @inheritDoc */ protected registerWorkerMessageListener( - messageChannel: ThreadWorkerWithMessageChannel, + worker: ThreadWorkerWithMessageChannel, listener: (message: MessageValue) => void ): void { - messageChannel.port2?.on('message', listener) + worker.port2?.on('message', listener) } /** @inheritDoc */