X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=eaa19ac8f384ed5ce591362696e13bfdf765ab5a;hb=aaf2bf9c2ec7712394d7ab9da12449262d894e60;hp=a8a06a39a764fdc105f886e34ad8aab1d2075119;hpb=01f4001e733ebc61423d3023d87b1399b6afa215;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index a8a06a39..eaa19ac8 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -3,6 +3,7 @@ import { Worker } from 'node:worker_threads'; import { WorkerAbstract } from './WorkerAbstract'; +import { WorkerConstants } from './WorkerConstants'; import { type MessageHandler, type WorkerData, @@ -51,7 +52,7 @@ export class WorkerSet extends WorkerAbstract { await this.startWorker(); } this.getLastWorker().postMessage({ - id: WorkerMessageEvents.START_WORKER_ELEMENT, + id: WorkerMessageEvents.startWorkerElement, data: elementData, }); this.getLastWorkerSetElement().numberOfWorkerElements++; @@ -89,12 +90,9 @@ export class WorkerSet extends WorkerAbstract { const worker = new Worker(this.workerScript); worker.on( 'message', - ( - this.workerOptions?.messageHandler ?? - (() => { - /* This is intentional */ - }) - ).bind(this) as MessageHandler + (this.workerOptions?.messageHandler ?? WorkerConstants.EMPTY_FUNCTION).bind( + this + ) as MessageHandler ); worker.on('error', WorkerUtils.defaultErrorHandler.bind(this) as (err: Error) => void); worker.on('exit', (code) => {