workerNode.info.ready = ready
workerNode.info.taskFunctionNames = taskFunctionNames
if (!this.readyEventEmitted && this.ready) {
- this.readyEventEmitted = true
this.emitter?.emit(PoolEvents.ready, this.info)
+ this.readyEventEmitted = true
}
}
this.getWorkerInfo(workerNodeKey).ready = false
}
- /** @inheritDoc */
- public hasWorkerNodeBackPressure (workerNodeKey: number): boolean {
- return (
- this.opts.enableTasksQueue === true &&
- this.workerNodes[workerNodeKey].hasBackPressure()
- )
- }
-
private hasBackPressure (): boolean {
return (
this.opts.enableTasksQueue === true &&