Clean worker from pool after it was destroyed (#146)

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

diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts
index 3d523890463c1d82a05d200dd16a269557107220..432feb3abb6b91017540561efcaa4f48608869da 100644 (file)
--- a/src/pools/cluster/dynamic.ts
+++ b/src/pools/cluster/dynamic.ts
@@ -63,12 +63,11 @@ export class DynamicClusterPool<
         return super.chooseWorker()
       }
       // All workers are busy, create a new worker
-      const worker = this.internalNewWorker()
+      const worker = this.createAndSetupWorker()
       worker.on('message', (message: MessageValue<Data>) => {
         if (message.kill) {
           this.sendToWorker(worker, { kill: 1 })
           void this.destroyWorker(worker)
-          this.removeWorker(worker)
         }
       })
       return worker