X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fworker%2Fcluster-worker.ts;h=2c326a67380e96589083a8bb451e4353180e232b;hb=2ea51d625067ca54eba5b8781ec8070dd28966d2;hp=4b1efaca384a92869b67460236aefea72953df9d;hpb=d56f6cfde3b9eeb2a5e4341b91ec474580a0c07a;p=poolifier.git diff --git a/src/worker/cluster-worker.ts b/src/worker/cluster-worker.ts index 4b1efaca..2c326a67 100644 --- a/src/worker/cluster-worker.ts +++ b/src/worker/cluster-worker.ts @@ -1,6 +1,6 @@ import type { Worker } from 'cluster' import { isMaster, worker } from 'cluster' -import type { JSONValue, MessageValue } from '../utility-types' +import type { MessageValue } from '../utility-types' import { AbstractWorker } from './abstract-worker' import type { WorkerOptions } from './worker-options' @@ -13,15 +13,15 @@ import type { WorkerOptions } from './worker-options' * If you use a `DynamicClusterPool` the extra workers that were created will be terminated, * but the minimum number of workers will be guaranteed. * - * @template Data Type of data this worker receives from pool's execution. - * @template Response Type of response the worker sends back to the main worker. + * @template Data Type of data this worker receives from pool's execution. This can only be serializable data. + * @template Response Type of response the worker sends back to the main worker. This can only be serializable data. * * @author [Christopher Quadflieg](https://github.com/Shinigami92) * @since 2.0.0 */ export class ClusterWorker< - Data extends JSONValue = JSONValue, - Response extends JSONValue = JSONValue + Data = unknown, + Response = unknown > extends AbstractWorker { /** * Constructs a new poolifier cluster worker. @@ -33,10 +33,12 @@ export class ClusterWorker< super('worker-cluster-pool:pioardi', isMaster, fn, worker, opts) } + /** @inheritdoc */ protected sendToMainWorker (message: MessageValue): void { this.getMainWorker().send(message) } + /** @inheritdoc */ protected handleError (e: Error | string): string { return e instanceof Error ? e.message : e }