worker.on('error', (error) => {
this.emitter?.emit(WorkerSetEvents.error, error);
if (this.workerOptions.poolOptions?.restartWorkerOnError) {
this.addWorkerSetElement();
}
});
worker.on('error', (error) => {
this.emitter?.emit(WorkerSetEvents.error, error);
if (this.workerOptions.poolOptions?.restartWorkerOnError) {
this.addWorkerSetElement();
}
});