X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fpools%2Fpool-worker.ts;h=e371e9c15fd7797b956023add35375eb04a326ac;hb=e5a5c0fc68a38b7d6316cc573c34313aa6ec30e9;hp=d46eda19c75cd51533562f06380a3a70cf8ef05e;hpb=bdaf31cd0e637aa466c78d54a49f157899a2cb3f;p=poolifier.git diff --git a/src/pools/pool-worker.ts b/src/pools/pool-worker.ts index d46eda19..e371e9c1 100644 --- a/src/pools/pool-worker.ts +++ b/src/pools/pool-worker.ts @@ -1,12 +1,3 @@ -import type { Worker as ClusterWorker } from 'cluster' -import type { Worker as WorkerThread } from 'worker_threads' -import type { Draft } from '../utility-types' - -/** - * Poolifier supported worker type. - */ -export type WorkerType = WorkerThread & ClusterWorker & Draft - /** * Callback invoked if the worker has received a message. */ @@ -28,46 +19,24 @@ export type OnlineHandler = (this: Worker) => void export type ExitHandler = (this: Worker, code: number) => void /** - * Basic interface that describes the minimum required implementation of listener events for a pool worker. + * Interface that describes the minimum required implementation of listener events for a pool worker. */ export interface IPoolWorker { /** - * Worker identifier. - */ - readonly id?: number - /** - * Register a listener to the message event. - * - * @param event `'message'`. - * @param handler The message handler. - */ - on(event: 'message', handler: MessageHandler): void - /** - * Register a listener to the error event. - * - * @param event `'error'`. - * @param handler The error handler. - */ - on(event: 'error', handler: ErrorHandler): void - /** - * Register a listener to the online event. - * - * @param event `'online'`. - * @param handler The online handler. - */ - on(event: 'online', handler: OnlineHandler): void - /** - * Register a listener to the exit event. + * Register an event listener. * - * @param event `'exit'`. - * @param handler The exit handler. + * @param event - The event. + * @param handler - The event listener. */ - on(event: 'exit', handler: ExitHandler): void + on: ((event: 'message', handler: MessageHandler) => void) & + ((event: 'error', handler: ErrorHandler) => void) & + ((event: 'online', handler: OnlineHandler) => void) & + ((event: 'exit', handler: ExitHandler) => void) /** * Register a listener to the exit event that will only performed once. * - * @param event `'exit'`. - * @param handler The exit handler. + * @param event - `'exit'`. + * @param handler - The exit handler. */ - once(event: 'exit', handler: ExitHandler): void + once: (event: 'exit', handler: ExitHandler) => void }