const { resolve, reject, workerSetElement } = this.promiseResponseMap.get(uuid)!
if (event === WorkerMessageEvents.addedWorkerElement) {
this.emitter?.emit(WorkerSetEvents.elementAdded, this.info)
- workerSetElement.numberOfWorkerElements++
+ ++workerSetElement.numberOfWorkerElements
resolve(data)
} else if (event === WorkerMessageEvents.workerElementError) {
this.emitter?.emit(WorkerSetEvents.elementError, data)
reject(data)
}
- this.promiseResponseMap.delete(message.uuid)
+ this.promiseResponseMap.delete(uuid)
}
})
worker.on('error', this.workerOptions.poolOptions?.errorHandler ?? EMPTY_FUNCTION)