X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Ffixed.ts;h=10ee92c57876663d07ae96ecdcde036013395126;hb=9e45c2c437217612e71b46b207a994f9106dff23;hp=81e7b3b7d08b4bb5624d993a15f7850d9d3bf2ba;hpb=aec509b85e7d73e9883c8885e27fc4e34fdaef1e;p=poolifier.git diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts index 81e7b3b7..10ee92c5 100644 --- a/src/pools/cluster/fixed.ts +++ b/src/pools/cluster/fixed.ts @@ -32,7 +32,7 @@ export interface ClusterPoolOptions extends PoolOptions { * This pool selects the workers 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 [Christopher Quadflieg](https://github.com/Shinigami92) * @since 2.0.0 */ @@ -66,7 +66,7 @@ export class FixedClusterPool< } /** @inheritDoc */ - public destroyWorker (worker: Worker): void { + protected destroyWorker (worker: Worker): void { this.sendToWorker(worker, { kill: 1 }) worker.kill() } @@ -100,6 +100,11 @@ export class FixedClusterPool< return PoolType.FIXED } + /** @inheritDoc */ + public get size (): number { + return this.numberOfWorkers + } + /** @inheritDoc */ protected get full (): boolean { return this.workerNodes.length === this.numberOfWorkers