X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fselection-strategies%2Fworker-choice-strategy-context.ts;h=5d26f82ba4f5784873c18eb037beed9b26a5e2f5;hb=3085fb0d77d3b14d33324875900d1d088828e12a;hp=e5fddc1b1fc5b400398b2e86bd0ac3b3fd6f97c9;hpb=a4958de2101f06e7096b83adbca82fcfd532a721;p=poolifier.git diff --git a/src/pools/selection-strategies/worker-choice-strategy-context.ts b/src/pools/selection-strategies/worker-choice-strategy-context.ts index e5fddc1b..5d26f82b 100644 --- a/src/pools/selection-strategies/worker-choice-strategy-context.ts +++ b/src/pools/selection-strategies/worker-choice-strategy-context.ts @@ -115,7 +115,7 @@ export class WorkerChoiceStrategyContext< } /** - * Updates the worker choice strategy internals in the context. + * Updates the worker node key in the worker choice strategy internals in the context. * * @returns `true` if the update is successful, `false` otherwise. */ @@ -131,17 +131,22 @@ export class WorkerChoiceStrategyContext< * Executes the worker choice strategy algorithm in the context. * * @returns The key of the worker node. + * @throws {@link https://nodejs.org/api/errors.html#class-error} If the worker node key is null or undefined. */ public execute (): number { - return ( + const workerNodeKey = ( this.workerChoiceStrategies.get( this.workerChoiceStrategy ) as IWorkerChoiceStrategy ).choose() + if (workerNodeKey == null) { + throw new Error('Worker node key chosen is null or undefined') + } + return workerNodeKey } /** - * Removes a worker node key from the worker choice strategy in the context. + * Removes the worker node key from the worker choice strategy in the context. * * @param workerNodeKey - The key of the worker node. * @returns `true` if the removal is successful, `false` otherwise.