X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=af80bcfbebcee352f2dc0c09dc6a6754e75ec0bf;hb=d1c7c37df866e26b32a2786b9ae83dfdfd96f7ba;hp=06989941fd7030c52286cd0c18a3c909d654c2db;hpb=af98b972cd1f5145852682b8167e4af0ff994260;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 06989941..af80bcfb 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -1,5 +1,5 @@ import type { TransferListItem } from 'node:worker_threads' -import type { EventEmitter, EventEmitterAsyncResource } from 'node:events' +import type { EventEmitterAsyncResource } from 'node:events' import type { TaskFunction } from '../worker/task-functions' import type { ErrorHandler, @@ -235,7 +235,7 @@ export interface IPool< * - `'taskError'`: Emitted when an error occurs while executing a task. * - `'backPressure'`: Emitted when all worker nodes have back pressure (i.e. their tasks queue is full: queue size \>= maximum queue size). */ - readonly emitter?: EventEmitter | EventEmitterAsyncResource + readonly emitter?: EventEmitterAsyncResource /** * Executes the specified function in the worker constructor with the task data input parameter. *