X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker-node.ts;h=4349ed72471b3614e227ab4d374df7f0aba17186;hb=5441aea6894a5031667db6447634fa5d97f69e36;hp=923fe9b222a4ea9dc4279294d51d0755f67f1ba7;hpb=019581cc38fe0b47645d9b2120f325ab37388be2;p=poolifier.git diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts index 923fe9b2..4349ed72 100644 --- a/src/pools/worker-node.ts +++ b/src/pools/worker-node.ts @@ -23,7 +23,6 @@ implements IWorkerNode { public readonly worker: Worker public readonly info: WorkerInfo public usage: WorkerUsage - public taskFunctions!: string[] private readonly tasksUsage: Map private readonly tasksQueue: Queue> @@ -89,12 +88,17 @@ implements IWorkerNode { /** @inheritdoc */ public getTaskWorkerUsage (name: string): WorkerUsage | undefined { + if (name === DEFAULT_TASK_NAME && !Array.isArray(this.info.taskFunctions)) { + throw new Error( + 'Cannot get task worker usage for default task function name when task function names list is not yet defined' + ) + } if ( name === DEFAULT_TASK_NAME && - Array.isArray(this.taskFunctions) && - this.taskFunctions.length > 1 + Array.isArray(this.info.taskFunctions) && + this.info.taskFunctions.length > 1 ) { - name = this.taskFunctions[1] + name = this.info.taskFunctions[1] } if (!this.tasksUsage.has(name)) { this.tasksUsage.set(name, this.initTaskWorkerUsage(name))