X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fworker%2FWorkerStaticPool.ts;h=7000ac9a45e7f0ea8d5de89a9ba3496782c59b63;hb=5edd8ba0f8978cfb3ca9d80f299d9748c6c5970e;hp=e49ac2613e97e0da7dc7857b7ec2a4b3cf3f2fd1;hpb=361c98f57255e5b91d123d5f2ba43ab533134b1a;p=e-mobility-charging-stations-simulator.git diff --git a/src/worker/WorkerStaticPool.ts b/src/worker/WorkerStaticPool.ts index e49ac261..7000ac9a 100644 --- a/src/worker/WorkerStaticPool.ts +++ b/src/worker/WorkerStaticPool.ts @@ -1,6 +1,4 @@ -import type EventEmitterAsyncResource from 'node:events'; - -import { FixedThreadPool, type PoolInfo } from 'poolifier'; +import { FixedThreadPool, type PoolEmitter, type PoolInfo } from 'poolifier'; import { WorkerAbstract } from './WorkerAbstract'; import type { WorkerData, WorkerOptions } from './WorkerTypes'; @@ -20,7 +18,7 @@ export class WorkerStaticPool extends WorkerAbstract { this.pool = new FixedThreadPool( this.workerOptions.poolMaxSize, this.workerScript, - this.workerOptions.poolOptions + this.workerOptions.poolOptions, ); } @@ -36,7 +34,7 @@ export class WorkerStaticPool extends WorkerAbstract { return undefined; } - get emitter(): EventEmitterAsyncResource | undefined { + get emitter(): PoolEmitter | undefined { return this.pool?.emitter; }