type: WorkerTypes.thread,
dynamic: false,
ready: false,
+ backPressure: false,
stealing: false
})
expect(threadWorkerNode.usage).toStrictEqual({
expect(threadWorkerNode.tasksQueueSize()).toBe(
threadWorkerNode.tasksQueue.size
)
- expect(threadWorkerNode.onBackPressureStarted).toBe(false)
+ expect(threadWorkerNode.setBackPressureFlag).toBe(false)
expect(threadWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
expect(clusterWorkerNode).toBeInstanceOf(WorkerNode)
type: WorkerTypes.cluster,
dynamic: false,
ready: false,
+ backPressure: false,
stealing: false
})
expect(clusterWorkerNode.usage).toStrictEqual({
expect(clusterWorkerNode.tasksQueueSize()).toBe(
clusterWorkerNode.tasksQueue.size
)
- expect(clusterWorkerNode.onBackPressureStarted).toBe(false)
+ expect(clusterWorkerNode.setBackPressureFlag).toBe(false)
expect(clusterWorkerNode.taskFunctionsUsage).toBeInstanceOf(Map)
})