X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fabstract-pool.ts;h=8e0a259af8ea3e6f0edad24f29dbb9b4e81821fe;hb=bc098b7f00e53e0edd6adb80fff694ef1a896c69;hp=a0fc76c371584d3e69855fe732d720db482cc0bf;hpb=8ea697554e82d9f2854acee9fddb8d2fe2d8f9c4;p=poolifier.git diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts index a0fc76c3..8e0a259a 100644 --- a/src/pools/abstract-pool.ts +++ b/src/pools/abstract-pool.ts @@ -622,7 +622,7 @@ export abstract class AbstractPool< for (const [workerNodeKey] of this.workerNodes.entries()) { this.workerNodes[workerNodeKey].addEventListener( 'emptyqueue', - this.handleEmptyQueueEvent + this.handleEmptyQueueEvent as EventListener ) } } @@ -631,7 +631,7 @@ export abstract class AbstractPool< for (const [workerNodeKey] of this.workerNodes.entries()) { this.workerNodes[workerNodeKey].removeEventListener( 'emptyqueue', - this.handleEmptyQueueEvent + this.handleEmptyQueueEvent as EventListener ) } } @@ -640,7 +640,7 @@ export abstract class AbstractPool< for (const [workerNodeKey] of this.workerNodes.entries()) { this.workerNodes[workerNodeKey].addEventListener( 'backpressure', - this.handleBackPressureEvent + this.handleBackPressureEvent as EventListener ) } } @@ -649,7 +649,7 @@ export abstract class AbstractPool< for (const [workerNodeKey] of this.workerNodes.entries()) { this.workerNodes[workerNodeKey].removeEventListener( 'backpressure', - this.handleBackPressureEvent + this.handleBackPressureEvent as EventListener ) } } @@ -1366,13 +1366,13 @@ export abstract class AbstractPool< if (this.opts.tasksQueueOptions?.taskStealing === true) { this.workerNodes[workerNodeKey].addEventListener( 'emptyqueue', - this.handleEmptyQueueEvent + this.handleEmptyQueueEvent as EventListener ) } if (this.opts.tasksQueueOptions?.tasksStealingOnBackPressure === true) { this.workerNodes[workerNodeKey].addEventListener( 'backpressure', - this.handleBackPressureEvent + this.handleBackPressureEvent as EventListener ) } } @@ -1601,7 +1601,7 @@ export abstract class AbstractPool< * @returns The worker information. */ protected getWorkerInfo (workerNodeKey: number): WorkerInfo { - return this.workerNodes[workerNodeKey].info + return this.workerNodes[workerNodeKey]?.info } /**