Benchmarks and performance enhancements (#209)

[poolifier.git] / src / pools / cluster / fixed.ts

diff --git a/src/pools/cluster/fixed.ts b/src/pools/cluster/fixed.ts
index 6246320e3072d18371646d431692abda06b85ea1..4ec81c07bab66b0ebad1cb3eed371ea568989ef0 100644 (file)
--- a/src/pools/cluster/fixed.ts
+++ b/src/pools/cluster/fixed.ts
@@ -76,13 +76,6 @@ export class FixedClusterPool<
     worker.on('message', listener)
   }
 
-  protected unregisterWorkerMessageListener<Message extends Data | Response> (
-    worker: Worker,
-    listener: (message: MessageValue<Message>) => void
-  ): void {
-    worker.removeListener('message', listener)
-  }
-
   protected createWorker (): Worker {
     return fork(this.opts.env)
   }
@@ -91,5 +84,6 @@ export class FixedClusterPool<
     // We will attach a listener for every task,
     // when task is completed the listener will be removed but to avoid warnings we are increasing the max listeners size
     worker.setMaxListeners(this.opts.maxTasks ?? 1000)
+    this.registerWorkerMessageListener(worker, super.workerListener())
   }
 }