X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=ea1ed241020637d0dcab4534b5bfdf4605891d6e;hb=48c7e1d6db4b3cbf82d17e191b2255066c462a71;hp=b8e0e31fb641b94080933a87f06779009e95e43a;hpb=a4385edc2344433c20fcb92d01cbe5a330b850b4;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index b8e0e31f..ea1ed241 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -86,7 +86,7 @@ export class WorkerSet extends WorkerAbstract { public async stop (): Promise { for (const workerSetElement of this.workerSet) { const worker = workerSetElement.worker - const waitWorkerExit = new Promise((resolve) => { + const waitWorkerExit = new Promise(resolve => { worker.once('exit', () => { resolve() }) @@ -105,9 +105,6 @@ export class WorkerSet extends WorkerAbstract { if (!this.started) { throw new Error('Cannot add a WorkerSet element: not started') } - if (this.workerSet == null) { - throw new Error("Cannot add a WorkerSet element: 'workerSet' property does not exist") - } const workerSetElement = await this.getWorkerSetElement() workerSetElement.worker.postMessage({ event: WorkerMessageEvents.startWorkerElement, @@ -140,7 +137,7 @@ export class WorkerSet extends WorkerAbstract { } }) worker.on('error', this.workerOptions.poolOptions?.errorHandler ?? EMPTY_FUNCTION) - worker.on('error', (error) => { + worker.on('error', error => { this.emitter?.emit(WorkerSetEvents.error, error) if ( this.workerOptions.poolOptions?.restartWorkerOnError === true &&