X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerSet.ts;h=eaa19ac8f384ed5ce591362696e13bfdf765ab5a;hb=42486f2357b011f9244c6b29f4e05185138ce8d1;hp=a79db16e0313deef9270cdb7a61b6e16398376c0;hpb=268a74bb051fcbbad532fd833f0d8fd2b33b6c64;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerSet.ts b/src/worker/WorkerSet.ts index a79db16e..eaa19ac8 100644 --- a/src/worker/WorkerSet.ts +++ b/src/worker/WorkerSet.ts @@ -1,8 +1,9 @@ // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. -import { Worker } from 'worker_threads'; +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) => {