X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fcluster-worker.ts;h=d972692ec6eb4f182479cac008c47a1f20b75d8d;hb=449cd15417158c0d1675a8aec8bcc514ff33b5a3;hp=201a516c56e1d8ab2a3d2d569c4d54d7f0fd484d;hpb=001cc6a4bd787b8ec8efab54674789018a6b6690;p=poolifier.git diff --git a/src/worker/cluster-worker.ts b/src/worker/cluster-worker.ts index 201a516c..d972692e 100644 --- a/src/worker/cluster-worker.ts +++ b/src/worker/cluster-worker.ts @@ -32,13 +32,7 @@ export class ClusterWorker< taskFunctions: TaskFunction | TaskFunctions, opts: WorkerOptions = {} ) { - super( - 'worker-cluster-pool:poolifier', - cluster.isPrimary, - cluster.worker as Worker, - taskFunctions, - opts - ) + super(cluster.isPrimary, cluster.worker as Worker, taskFunctions, opts) } /** @inheritDoc */ @@ -65,7 +59,9 @@ export class ClusterWorker< } /** @inheritDoc */ - protected sendToMainWorker (message: MessageValue): void { + protected readonly sendToMainWorker = ( + message: MessageValue + ): void => { this.getMainWorker().send({ ...message, workerId: this.id }) } }