1 import type { Worker
} from
'cluster'
2 import type { MessagePort
} from
'worker_threads'
3 import type { IWorker
} from
'./pools/abstract-pool'
4 import type { KillBehavior
} from
'./worker/worker-options'
7 * Make all properties in T non-readonly.
9 export type Draft
<T
> = { -readonly [P
in keyof T
]?: T
[P
] }
12 * Message object that is passed between worker and main worker.
14 export interface MessageValue
<
16 MainWorker
extends Worker
| MessagePort
| unknown
= unknown
19 * Input data that will be passed to the worker.
29 readonly kill
?: KillBehavior
| 1
33 readonly error
?: string
35 * Reference to main worker.
37 * _Only for internal use_
39 readonly parent?: MainWorker
43 * An object holding the worker that will be used to resolve/rejects the promise later on.
45 * @template Worker Type of worker.
46 * @template Response Type of response of execution. This can only be serializable data.
48 export interface PromiseWorkerResponseWrapper
<
49 Worker
extends IWorker
,
53 * Resolve callback to fulfill the promise.
55 readonly resolve
: (value
: Response
) => void
57 * Reject callback to reject the promise.
59 readonly reject
: (reason
?: string) => void
61 * The worker that has the assigned task.
63 readonly worker
: Worker