X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fpool.ts;h=f4d9c7bba67d18d3c48a212159bf606fe409cfcf;hb=2115798751b31f025acae1ff8c4f5cbcec8ad3af;hp=0bde23befc95521132d619c5d2299008bf9ddd81;hpb=90d7d101196cf9702ccc1d220dd33cca67a427b0;p=poolifier.git diff --git a/src/pools/pool.ts b/src/pools/pool.ts index 0bde23be..f4d9c7bb 100644 --- a/src/pools/pool.ts +++ b/src/pools/pool.ts @@ -42,9 +42,10 @@ export class PoolEmitter extends EventEmitter {} * Enumeration of pool events. */ export const PoolEvents = Object.freeze({ - full: 'full', ready: 'ready', busy: 'busy', + full: 'full', + destroy: 'destroy', error: 'error', taskError: 'taskError' } as const) @@ -110,6 +111,10 @@ export interface TasksQueueOptions { * @typeParam Worker - Type of worker. */ export interface PoolOptions { + /** + * A function that will listen for online event on each worker. + */ + onlineHandler?: OnlineHandler /** * A function that will listen for message event on each worker. */ @@ -118,10 +123,6 @@ export interface PoolOptions { * A function that will listen for error event on each worker. */ errorHandler?: ErrorHandler - /** - * A function that will listen for online event on each worker. - */ - onlineHandler?: OnlineHandler /** * A function that will listen for exit event on each worker. */ @@ -183,9 +184,10 @@ export interface IPool< * * Events that can currently be listened to: * - * - `'full'`: Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected. * - `'ready'`: Emitted when the number of workers created in the pool has reached the minimum size expected and are ready. * - `'busy'`: Emitted when the number of workers created in the pool has reached the maximum size expected and are executing at least one task. + * - `'full'`: Emitted when the pool is dynamic and the number of workers created has reached the maximum size expected. + * - '`destroy`': Emitted when the pool is destroyed. * - `'error'`: Emitted when an uncaught error occurs. * - `'taskError'`: Emitted when an error occurs while executing a task. */