QueueConfigFromEffect<F, O>models
Source src/internal/workPool.ts:13257 lines
export type type QueueConfigFromEffect<
F extends QueueWorkerEffect<any, any, any, any>,
O extends
| WorkPoolOptionsWithoutItemSchema<
any,
any,
any
>
| WorkPoolOptionsWithItemSchema<any, any, any>
| undefined = undefined
> = {
readonly effect: F
} & (O extends undefined ? unknown : O)
function (type parameter) F in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends WorkPoolOptionsWithoutItemSchema<any, any, any> | WorkPoolOptionsWithItemSchema<any, any, any> | undefined = undefined>F extends type QueueWorkerEffect<
T,
E,
EEnqueue = never,
R = never
> = (
item: T,
ctx: EffectContext<T, EEnqueue, R>
) => Effect.Effect<void, E, R>
function (type parameter) O in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends WorkPoolOptionsWithoutItemSchema<any, any, any> | WorkPoolOptionsWithItemSchema<any, any, any> | undefined = undefined>O extends
| type WorkPoolOptionsWithoutItemSchema<
T,
E,
R
> = {
readonly name?: string | undefined
readonly paused?: boolean | undefined
readonly autoStart?: boolean | undefined
readonly concurrency?: number | undefined
readonly rateLimit?:
| WorkPoolRateLimitOptions
| undefined
readonly capacity?: number | undefined
readonly laneCount?: number | undefined
readonly takeAlgorithm?:
| TakeAlgorithm
| undefined
readonly key?: ((item: T) => string) | undefined
readonly attempts?: number | undefined
readonly shutdownMode?:
| "drain"
| "finishActive"
| undefined
readonly itemSchema?: undefined | undefined
readonly onFailure?:
| QueueOnFailure<T, E, R>
| undefined
readonly refill?:
| QueueRefill<T, E, never, R, void>
| undefined
}
type WorkPoolOptionsWithItemSchema<T, E, R> = {
readonly name?: string | undefined;
readonly paused?: boolean | undefined;
readonly autoStart?: boolean | undefined;
readonly concurrency?: number | undefined;
readonly rateLimit?: WorkPoolRateLimitOptions | undefined;
readonly capacity?: number | undefined;
readonly laneCount?: number | undefined;
readonly takeAlgorithm?: TakeAlgorithm | undefined;
readonly key?: ((item: T) => string) | undefined;
readonly attempts?: number | undefined;
readonly shutdownMode?: "drain" | "finishActive" | undefined;
readonly itemSchema: Schema.Codec<T, unknown, never, never>;
readonly onFailure?: QueueOnFailure<T, E, R> | undefined;
readonly refill?: QueueRefill<...> | undefined;
readonly store?: {
...;
} | undefined;
}
effect: F extends QueueWorkerEffect<any, any, any, any>effect: function (type parameter) F in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends WorkPoolOptionsWithoutItemSchema<any, any, any> | WorkPoolOptionsWithItemSchema<any, any, any> | undefined = undefined>F } & (function (type parameter) O in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends WorkPoolOptionsWithoutItemSchema<any, any, any> | WorkPoolOptionsWithItemSchema<any, any, any> | undefined = undefined>O extends undefined ? unknown : function (type parameter) O in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends WorkPoolOptionsWithoutItemSchema<any, any, any> | WorkPoolOptionsWithItemSchema<any, any, any> | undefined = undefined>O);