PriorityConfigWithItemSchema<T, E, R>models
Source src/WorkPool.ts:1021 lines
export type type PriorityConfigWithItemSchema<T, E, R> = Omit<WorkPoolConfigBase<T>, "laneCount"> & WorkPoolPriorityLaneConfig & {
readonly itemSchema: Schema.Codec<T, unknown, never, never>;
readonly effect: (item: T, ctx: EffectContext<T, QueueEnqueueErrors, R>) => Effect.Effect<void, E, R>;
readonly onFailure?: QueueOnFailure<T, E, R> | undefined;
readonly refill?: WorkPoolPriorityRefill<T, E, QueueEnqueueErrors, R> | undefined;
readonly store?: {
...;
} | undefined;
}
function (type parameter) T in type PriorityConfigWithItemSchema<T, E, R>T, function (type parameter) E in type PriorityConfigWithItemSchema<T, E, R>E, function (type parameter) R in type PriorityConfigWithItemSchema<T, E, R>R> = type WorkPoolPriorityConfigWithItemSchema<T, E, R> = Omit<WorkPoolConfigBase<T>, "laneCount"> & WorkPoolPriorityLaneConfig & {
readonly itemSchema: Schema.Codec<T, unknown, never, never>;
readonly effect: (item: T, ctx: EffectContext<T, QueueEnqueueErrors, R>) => Effect.Effect<void, E, R>;
readonly onFailure?: QueueOnFailure<T, E, R>;
readonly refill?: WorkPoolPriorityRefill<T, E, QueueEnqueueErrors, R>;
readonly store?: QueueStoreWriter<T, E, void>;
}
function (type parameter) T in type PriorityConfigWithItemSchema<T, E, R>T, function (type parameter) E in type PriorityConfigWithItemSchema<T, E, R>E, function (type parameter) R in type PriorityConfigWithItemSchema<T, E, R>R>;