From 62242b7d286af3251b00a48a90491ff1f4b1fac5 Mon Sep 17 00:00:00 2001
From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= <jerome.benoit@piment-noir.org>
Date: Tue, 8 Jul 2025 19:28:17 +0200
Subject: [PATCH] refactor: cleanup task function ops method
MIME-Version: 1.0
Content-Type: text/plain; charset=utf8
Content-Transfer-Encoding: 8bit

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>
---
 src/pools/abstract-pool.ts | 12 +++---------
 1 file changed, 3 insertions(+), 9 deletions(-)

diff --git a/src/pools/abstract-pool.ts b/src/pools/abstract-pool.ts
index 2d8255f92..088696b40 100644
--- a/src/pools/abstract-pool.ts
+++ b/src/pools/abstract-pool.ts
@@ -2316,9 +2316,9 @@ export abstract class AbstractPool<
     const taskFunctionOperationsListener = (
       message: MessageValue<Response>,
       resolve: (value: boolean | PromiseLike<boolean>) => void,
-      reject: (reason?: unknown) => void,
-      responsesReceived: MessageValue<Response>[]
+      reject: (reason?: unknown) => void
     ): void => {
+      const responsesReceived: MessageValue<Response>[] = []
       this.checkMessageWorkerId(message)
       if (
         message.taskFunctionOperationStatus != null &&
@@ -2351,14 +2351,8 @@ export abstract class AbstractPool<
     let listener: ((message: MessageValue<Response>) => void) | undefined
     try {
       return await new Promise<boolean>((resolve, reject) => {
-        const responsesReceived: MessageValue<Response>[] = []
         listener = (message: MessageValue<Response>) => {
-          taskFunctionOperationsListener(
-            message,
-            resolve,
-            reject,
-            responsesReceived
-          )
+          taskFunctionOperationsListener(message, resolve, reject)
         }
         for (const workerNodeKey of targetWorkerNodeKeys) {
           this.registerWorkerMessageListener(workerNodeKey, listener)
-- 
2.43.0