feat: add worker set events

Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>

diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts
index 19ed8393f171a64d37e4e3d3e871cacf81f17539..bc1a4c0871547b5485d7ab8c443733741e90d8c3 100644 (file)
--- a/src/worker/WorkerSet.ts
+++ b/src/worker/WorkerSet.ts
@@ -10,6 +10,7 @@ import { WorkerConstants } from './WorkerConstants';
 import {
   type SetInfo,
   type WorkerData,
+  type WorkerMessage,
   WorkerMessageEvents,
   type WorkerOptions,
   type WorkerSetElement,
@@ -116,6 +117,13 @@ export class WorkerSet extends WorkerAbstract<WorkerData> {
       'message',
       this.workerOptions.poolOptions?.messageHandler ?? WorkerConstants.EMPTY_FUNCTION,
     );
+    worker.on('message', (message: WorkerMessage<WorkerData>) => {
+      if (message.event === WorkerMessageEvents.startedWorkerElement) {
+        this.emitter?.emit(WorkerSetEvents.elementStarted, message.data);
+      } else if (message.event === WorkerMessageEvents.startWorkerElementError) {
+        this.emitter?.emit(WorkerSetEvents.elementError, message.data);
+      }
+    });
     worker.on(
       'error',
       this.workerOptions.poolOptions?.errorHandler ?? WorkerConstants.EMPTY_FUNCTION,

diff --git a/src/worker/WorkerTypes.ts b/src/worker/WorkerTypes.ts
index 653cfedf66d58c4855387da0393f03b97e9b8af8..12d5ab26f13f7d62c408f20a8f55f09b862ca7b5 100644 (file)
--- a/src/worker/WorkerTypes.ts
+++ b/src/worker/WorkerTypes.ts
@@ -20,6 +20,8 @@ export interface SetInfo {
 
 export enum WorkerSetEvents {
   error = 'error',
+  elementStarted = 'elementStarted',
+  elementError = 'elementError',
 }
 
 export const WorkerEvents = {