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 359dc26c1c3649380572c7d6609961b534225863..d8044032014d02d36e6cbe70ffd10026f6a085ea 100644 (file)
--- a/src/pools/worker-node.ts
+++ b/src/pools/worker-node.ts
@@ -1,7 +1,7 @@
 import { MessageChannel } from 'node:worker_threads'
 import { CircularArray } from '../circular-array'
 import type { Task } from '../utility-types'
-import { DEFAULT_TASK_NAME } from '../utils'
+import { DEFAULT_TASK_NAME, once } from '../utils'
 import { Deque } from '../deque'
 import {
   type IWorker,
@@ -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()) {
-      this.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()) {
-      this.once(this.onBackPressure)(this.info.id as number)
+      once(this.onBackPressure, this)(this.info.id as number)
     }
     return tasksQueueSize
   }
@@ -271,28 +271,4 @@ implements IWorkerNode<Worker, Data> {
       return worker.id
     }
   }
-
-  /**
-   * Executes a function once at a time.
-   *
-   * @param fn - The function to execute.
-   * @param context - The context to bind the function to.
-   * @returns The function to execute.
-   */
-  private once (
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    fn: (...args: any[]) => void,
-    context = this
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-  ): (...args: any[]) => void {
-    let called = false
-    // eslint-disable-next-line @typescript-eslint/no-explicit-any
-    return function (...args: any[]): void {
-      if (!called) {
-        called = true
-        fn.apply(context, args)
-        called = false
-      }
-    }
-  }
 }