X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fpools%2Fworker.ts;h=716376faf54ac6925cf4d4ff2ea4804e1d2cb38e;hb=3dd69d8ee8aa2132fccb106720a9f5ae67b92cc8;hp=8d62712b5d598ada970ae337ddee7eb2406f9193;hpb=d29bce7c35c0be75535b4d1eb0f22ef38b3f8204;p=poolifier.git diff --git a/src/pools/worker.ts b/src/pools/worker.ts index 8d62712b..716376fa 100644 --- a/src/pools/worker.ts +++ b/src/pools/worker.ts @@ -1,4 +1,5 @@ import type { CircularArray } from '../circular-array' +import type { Queue } from '../queue' /** * Callback invoked if the worker has received a message. @@ -90,14 +91,14 @@ export interface IWorker { * Register an event listener. * * @param event - The event. - * @param handler - The event listener. + * @param handler - The event handler. */ 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. + * Register a listener to the exit event that will only be performed once. * * @param event - `'exit'`. * @param handler - The exit handler. @@ -124,5 +125,5 @@ export interface WorkerNode { /** * Worker node tasks queue. */ - readonly tasksQueue: Array> + readonly tasksQueue: Queue> }