X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerStaticPool.ts;h=23112a6c566ff0b95f6f07cf48b606332ab1b7fd;hb=97613dc6750d81a7e5ef5c8ff4a754b2e382cc00;hp=3eaffff4b48a7c11e4c6c5fa3026b4c9f042b551;hpb=e7aeea18e189dd087c8f951cf77a253e2818ae90;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerStaticPool.ts b/src/worker/WorkerStaticPool.ts index 3eaffff4..23112a6c 100644 --- a/src/worker/WorkerStaticPool.ts +++ b/src/worker/WorkerStaticPool.ts @@ -1,6 +1,6 @@ -import { WorkerData, WorkerOptions } from '../types/Worker'; - import { FixedThreadPool } from 'poolifier'; + +import type { WorkerData, WorkerOptions } from '../types/Worker'; import Utils from '../utils/Utils'; import WorkerAbstract from './WorkerAbstract'; import { WorkerUtils } from './WorkerUtils'; @@ -16,6 +16,8 @@ export default class WorkerStaticPool extends WorkerAbstract { */ constructor(workerScript: string, workerOptions?: WorkerOptions) { super(workerScript, workerOptions); + this.workerOptions.poolOptions.errorHandler = + this.workerOptions?.poolOptions?.errorHandler ?? WorkerUtils.defaultErrorHandler; this.workerOptions.poolOptions.exitHandler = this.workerOptions?.poolOptions?.exitHandler ?? WorkerUtils.defaultExitHandler; this.pool = new FixedThreadPool(