X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fcluster%2Fdynamic.ts;h=432feb3abb6b91017540561efcaa4f48608869da;hb=45dbbb14328a173cad05ddcf21b5acf7f6460bb8;hp=3d523890463c1d82a05d200dd16a269557107220;hpb=50eceb07c3713782d1d6bbe49d3fe47318e45c93;p=poolifier.git diff --git a/src/pools/cluster/dynamic.ts b/src/pools/cluster/dynamic.ts index 3d523890..432feb3a 100644 --- 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) => { if (message.kill) { this.sendToWorker(worker, { kill: 1 }) void this.destroyWorker(worker) - this.removeWorker(worker) } }) return worker