QueueConfigFromEffect<F, O>models
Source src/internal/queueHyperlink.ts:13137 lines
export type type QueueConfigFromEffect<
F extends QueueWorkerEffect<any, any, any, any>,
O extends
| QueueHyperlinkOptionsWithoutItemSchema<
any,
any,
any
>
| QueueHyperlinkOptionsWithItemSchema<
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 QueueHyperlinkOptionsWithoutItemSchema<any, any, any> | QueueHyperlinkOptionsWithItemSchema<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 QueueHyperlinkOptionsWithoutItemSchema<any, any, any> | QueueHyperlinkOptionsWithItemSchema<any, any, any> | undefined = undefined>O extends
| type QueueHyperlinkOptionsWithoutItemSchema<
T,
E,
R
> = {
readonly name?: string | undefined
readonly paused?: boolean | undefined
readonly autoStart?: boolean | undefined
readonly concurrency?: number | undefined
readonly rateLimit?:
| QueueHyperlinkRateLimitOptions
| undefined
readonly capacity?: number | undefined
readonly levelCount?: number | undefined
readonly takeAlgorithm?: TakeAlgorithm
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 QueueHyperlinkOptionsWithItemSchema<T, E, R> = {
readonly name?: string | undefined;
readonly paused?: boolean | undefined;
readonly autoStart?: boolean | undefined;
readonly concurrency?: number | undefined;
readonly rateLimit?: QueueHyperlinkRateLimitOptions | undefined;
readonly capacity?: number | undefined;
readonly levelCount?: number | undefined;
readonly takeAlgorithm?: TakeAlgorithm;
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?: QueueStoreWriter<T, E, A>;
}
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 QueueHyperlinkOptionsWithoutItemSchema<any, any, any> | QueueHyperlinkOptionsWithItemSchema<any, any, any> | undefined = undefined>F } & (function (type parameter) O in type QueueConfigFromEffect<F extends QueueWorkerEffect<any, any, any, any>, O extends QueueHyperlinkOptionsWithoutItemSchema<any, any, any> | QueueHyperlinkOptionsWithItemSchema<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 QueueHyperlinkOptionsWithoutItemSchema<any, any, any> | QueueHyperlinkOptionsWithItemSchema<any, any, any> | undefined = undefined>O);