X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futility-types.ts;h=be0ed287633b24e211e46024f736aefc033701e3;hb=2761efb4184ad22cef774c7707023c354e8f8f04;hp=28bf19e256abaef2f619051773ad55456643b842;hpb=5c4d16da7677746e563fdcfe7f82cbb842d1c9e6;p=poolifier.git diff --git a/src/utility-types.ts b/src/utility-types.ts index 28bf19e2..be0ed287 100644 --- a/src/utility-types.ts +++ b/src/utility-types.ts @@ -1,6 +1,6 @@ import type { EventLoopUtilization } from 'node:perf_hooks' +import type { MessagePort } from 'node:worker_threads' import type { KillBehavior } from './worker/worker-options' -import type { IWorker } from './pools/worker' /** * Task error. @@ -115,32 +115,32 @@ export interface MessageValue */ readonly ready?: boolean /** - * Whether the worker starts or stops its aliveness check. + * Whether the worker starts or stops its activity check. */ - readonly checkAlive?: boolean + readonly checkActive?: boolean + /** + * Message port. + */ + readonly port?: MessagePort } /** - * An object holding the execution response promise resolve/reject callbacks. + * An object holding the task execution response promise resolve/reject callbacks. * - * @typeParam Worker - Type of worker. * @typeParam Response - Type of execution response. This can only be structured-cloneable data. * @internal */ -export interface PromiseResponseWrapper< - Worker extends IWorker, - Response = unknown -> { +export interface PromiseResponseWrapper { /** * Resolve callback to fulfill the promise. */ - readonly resolve: (value: Response) => void + readonly resolve: (value: Response | PromiseLike) => void /** * Reject callback to reject the promise. */ - readonly reject: (reason?: string) => void + readonly reject: (reason?: unknown) => void /** - * The worker handling the execution. + * The worker node key executing the task. */ - readonly worker: Worker + readonly workerNodeKey: number }