X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fcluster-worker.ts;h=d9f6e64756fa94d234023fcd200d3681cd621783;hb=refs%2Fheads%2Fmaster;hp=325b7a410b6cb7686ebee51f1d37b06043622fad;hpb=ded253e27e59ae936fe91d789d8454b7eb11dd6a;p=poolifier.git diff --git a/src/worker/cluster-worker.ts b/src/worker/cluster-worker.ts index 325b7a41..d9f6e647 100644 --- a/src/worker/cluster-worker.ts +++ b/src/worker/cluster-worker.ts @@ -13,7 +13,6 @@ import type { WorkerOptions } from './worker-options.js' * * If you use a `DynamicClusterPool` the extra workers that were created will be terminated, * but the minimum number of workers will be guaranteed. - * * @typeParam Data - Type of data this worker receives from pool's execution. This can only be structured-cloneable data. * @typeParam Response - Type of response the worker sends back to the main worker. This can only be structured-cloneable data. * @author [Christopher Quadflieg](https://github.com/Shinigami92) @@ -25,7 +24,6 @@ export class ClusterWorker< > extends AbstractWorker { /** * Constructs a new poolifier cluster worker. - * * @param taskFunctions - Task function(s) processed by the worker when the pool's `execution` function is invoked. * @param opts - Options for the worker. */ @@ -43,12 +41,12 @@ export class ClusterWorker< this.getMainWorker().on('message', this.messageListener.bind(this)) this.sendToMainWorker({ ready: true, - taskFunctionNames: this.listTaskFunctionNames() + taskFunctionsProperties: this.listTaskFunctionsProperties(), }) } catch { this.sendToMainWorker({ ready: false, - taskFunctionNames: this.listTaskFunctionNames() + taskFunctionsProperties: this.listTaskFunctionsProperties(), }) } } @@ -65,7 +63,7 @@ export class ClusterWorker< ): void => { this.getMainWorker().send({ ...message, - workerId: this.id + workerId: this.id, } satisfies MessageValue) } }