X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2Fcluster-worker.ts;h=c43e7f75a7586d2b2a9fa6633eea7da6e44697bf;hb=e677f6c55e0bb599d8e589a937a928229ecd6fea;hp=2a3961b37f02836d52c7972f98ee150c02904281;hpb=b6b3245344bd453ea91fa3d74acd5145f70d84fd;p=poolifier.git diff --git a/src/worker/cluster-worker.ts b/src/worker/cluster-worker.ts index 2a3961b3..c43e7f75 100644 --- a/src/worker/cluster-worker.ts +++ b/src/worker/cluster-worker.ts @@ -13,8 +13,8 @@ import type { TaskFunctions, WorkerFunction } from './worker-functions' * 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 serializable data. - * @typeParam Response - Type of response the worker sends back to the main worker. This can only be serializable data. + * @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) * @since 2.0.0 */ @@ -38,18 +38,18 @@ export class ClusterWorker< 'worker-cluster-pool:poolifier', cluster.isPrimary, taskFunctions, - cluster.worker, + cluster.worker as Worker, opts ) } /** @inheritDoc */ - protected sendToMainWorker (message: MessageValue): void { - this.getMainWorker().send(message) + protected get id (): number { + return this.getMainWorker().id } /** @inheritDoc */ - protected handleError (e: Error | string): string { - return e instanceof Error ? e.message : e + protected sendToMainWorker (message: MessageValue): void { + this.getMainWorker().send(message) } }