From 0016bf241066879bd7112e57ca8bf295438761b4 Mon Sep 17 00:00:00 2001
From: =?utf8?q?J=C3=A9r=C3=B4me=20Benoit?= <jerome.benoit@piment-noir.org>
Date: Thu, 21 Aug 2025 22:46:31 +0200
Subject: [PATCH] perf: missed worket set event emission control
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/worker/WorkerSet.ts | 6 +++++-
 1 file changed, 5 insertions(+), 1 deletion(-)

diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts
index 1fcdc353..50db7559 100644
--- a/src/worker/WorkerSet.ts
+++ b/src/worker/WorkerSet.ts
@@ -239,7 +239,11 @@ export class WorkerSet<D extends WorkerData, R extends WorkerData> extends Worke
       }
       worker.unref()
       // eslint-disable-next-line promise/no-promise-in-callback
-      worker.terminate().catch((error: unknown) => this.emitter?.emit(WorkerSetEvents.error, error))
+      worker.terminate().catch((error: unknown) => {
+        if (this.emitter != null && this.emitter.listenerCount(WorkerSetEvents.error) > 0) {
+          this.emitter.emit(WorkerSetEvents.error, error)
+        }
+      })
     })
     worker.on('online', this.workerOptions.poolOptions?.onlineHandler ?? EMPTY_FUNCTION)
     worker.on('exit', this.workerOptions.poolOptions?.exitHandler ?? EMPTY_FUNCTION)
-- 
2.43.0