build(deps-dev): apply updates

[poolifier.git] / src / pools / worker-node.ts

diff --git a/src/pools/worker-node.ts b/src/pools/worker-node.ts
index 208acdab423bc3293aa603165c05ef4bb44da31a..d8044032014d02d36e6cbe70ffd10026f6a085ea 100644 (file)
--- a/src/pools/worker-node.ts
+++ b/src/pools/worker-node.ts
@@ -94,7 +94,7 @@ implements IWorkerNode<Worker, Data> {
   public enqueueTask (task: Task<Data>): number {
     const tasksQueueSize = this.tasksQueue.push(task)
     if (this.onBackPressure != null && this.hasBackPressure()) {
-      once(this.onBackPressure)(this.info.id as number)
+      once(this.onBackPressure, this)(this.info.id as number)
     }
     return tasksQueueSize
   }
@@ -103,7 +103,7 @@ implements IWorkerNode<Worker, Data> {
   public unshiftTask (task: Task<Data>): number {
     const tasksQueueSize = this.tasksQueue.unshift(task)
     if (this.onBackPressure != null && this.hasBackPressure()) {
-      once(this.onBackPressure)(this.info.id as number)
+      once(this.onBackPressure, this)(this.info.id as number)
     }
     return tasksQueueSize
   }