X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Futility-types.ts;h=c4a8bf115174d6d60bb114975dfabc81f4a75c9f;hb=7c89e6a4cb61feed3743298f9813871af02df875;hp=28bf19e256abaef2f619051773ad55456643b842;hpb=3557031d88b5ff00ea86695728b3ba3af46e9faa;p=poolifier.git diff --git a/src/utility-types.ts b/src/utility-types.ts index 28bf19e2..c4a8bf11 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. * - * @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 handling the execution. */ - readonly worker: Worker + readonly workerNodeKey: number }