X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Fdynamic.ts;h=d4f270a373bc4e0c79198edf7538cb55a62f5e9d;hb=184855e69fea29f1018024a34be10de2c8e3141a;hp=c42e02b0cbfc0fc2ea0b2cd53f200739650f8267;hpb=027063571693f211b35c8851566a063201adb9af;p=poolifier.git diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts index c42e02b0..d4f270a3 100644 --- a/src/pools/cluster/dynamic.ts +++ b/src/pools/cluster/dynamic.ts @@ -1,6 +1,5 @@ -import { PoolType } from '../pool' -import type { ClusterPoolOptions } from './fixed' -import { FixedClusterPool } from './fixed' +import { type PoolType, PoolTypes } from '../pool' +import { type ClusterPoolOptions, FixedClusterPool } from './fixed' /** * A cluster pool with a dynamic number of workers, but a guaranteed minimum number of workers. @@ -36,12 +35,17 @@ export class DynamicClusterPool< /** @inheritDoc */ public get type (): PoolType { - return PoolType.DYNAMIC + return PoolTypes.dynamic + } + + /** @inheritDoc */ + protected get maxSize (): number { + return this.max } /** @inheritDoc */ protected get full (): boolean { - return this.workerNodes.length === this.max + return this.workerNodes.length >= this.max } /** @inheritDoc */