Skip to content

Commit dcdb30a

Browse files
committed
refactor: cleanup task function ops method
Signed-off-by: Jérôme Benoit <[email protected]>
1 parent 0776b29 commit dcdb30a

File tree

1 file changed

+2
-8
lines changed

1 file changed

+2
-8
lines changed

src/pools/abstract-pool.ts

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -859,8 +859,8 @@ export abstract class AbstractPool<
859859
message: MessageValue<Response>,
860860
resolve: (value: boolean | PromiseLike<boolean>) => void,
861861
reject: (reason?: unknown) => void,
862-
responsesReceived: MessageValue<Response>[],
863862
): void => {
863+
const responsesReceived: MessageValue<Response>[] = []
864864
this.checkMessageWorkerId(message)
865865
if (
866866
message.taskFunctionOperationStatus != null &&
@@ -894,14 +894,8 @@ export abstract class AbstractPool<
894894
let listener: ((message: MessageValue<Response>) => void) | undefined
895895
try {
896896
return await new Promise<boolean>((resolve, reject) => {
897-
const responsesReceived: MessageValue<Response>[] = []
898897
listener = (message: MessageValue<Response>) => {
899-
taskFunctionOperationsListener(
900-
message,
901-
resolve,
902-
reject,
903-
responsesReceived,
904-
)
898+
taskFunctionOperationsListener(message, resolve, reject)
905899
}
906900
for (const workerNodeKey of targetWorkerNodeKeys) {
907901
this.registerWorkerMessageListener(workerNodeKey, listener)

0 commit comments

Comments
 (0)