WorkPoolOptionsWithItemSchema<T, E, R>models
Source src/internal/workPool.ts:11944 lines
export type 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;
}
function (type parameter) T in type WorkPoolOptionsWithItemSchema<T, E, R>T, function (type parameter) E in type WorkPoolOptionsWithItemSchema<T, E, R>E, function (type parameter) R in type WorkPoolOptionsWithItemSchema<T, E, R>R> = type Omit<T, K extends keyof any> = {
[P in Exclude<keyof T, K>]: T[P]
}
Construct a type with the properties of T except for those in type K.
Omit<
type WorkPoolConfigWithItemSchema<
T,
E,
R,
A = void
> = WorkPoolConfigBase<T> & {
readonly itemSchema: Schema.Codec<
T,
unknown,
never,
never
>
readonly effect: (
item: T,
ctx: EffectContext<T, QueueEnqueueErrors, R>
) => Effect.Effect<A, E, R>
readonly onFailure?: QueueOnFailure<T, E, R>
readonly refill?: QueueRefill<
T,
E,
QueueEnqueueErrors,
R,
A
>
readonly store?: QueueStoreWriter<T, E, A>
}
A
WorkPool
config that carries an explicit itemSchema (typed items over the wire).
WorkPoolConfigWithItemSchema<function (type parameter) T in type WorkPoolOptionsWithItemSchema<T, E, R>T, function (type parameter) E in type WorkPoolOptionsWithItemSchema<T, E, R>E, function (type parameter) R in type WorkPoolOptionsWithItemSchema<T, E, R>R>,
"effect"
>;
Referenced by 1 symbols