WorkPoolConfig<T, E, R, A>Configuration for WorkPool.make.
modelsWorkPool.make
Source src/internal/workPool.ts:11733 lines
export type type WorkPoolConfig<T, E, R, A = void> =
| WorkPoolConfigWithoutItemSchema<T, E, R>
| WorkPoolConfigWithItemSchema<T, E, R, A>
Configuration for
WorkPool.make
.
WorkPoolConfig<function (type parameter) T in type WorkPoolConfig<T, E, R, A = void>T, function (type parameter) E in type WorkPoolConfig<T, E, R, A = void>E, function (type parameter) R in type WorkPoolConfig<T, E, R, A = void>R, function (type parameter) A in type WorkPoolConfig<T, E, R, A = void>A = void> =
| type WorkPoolConfigWithoutItemSchema<
T,
E,
R
> = WorkPoolConfigBase<T> & {
readonly itemSchema?: undefined
readonly effect: (
item: T,
ctx: EffectContext<T, never, R>
) => Effect.Effect<void, E, R>
readonly onFailure?: QueueOnFailure<T, E, R>
readonly refill?: QueueRefill<T, E, never, R>
}
Queue configuration without
WorkPoolConfigBase
item schema.
Enqueue helpers on
QueueHandle
and the
EffectContext
do not fail with
schema validation errors.
WorkPoolConfigWithoutItemSchema<function (type parameter) T in type WorkPoolConfig<T, E, R, A = void>T, function (type parameter) E in type WorkPoolConfig<T, E, R, A = void>E, function (type parameter) R in type WorkPoolConfig<T, E, R, A = void>R>
| 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 WorkPoolConfig<T, E, R, A = void>T, function (type parameter) E in type WorkPoolConfig<T, E, R, A = void>E, function (type parameter) R in type WorkPoolConfig<T, E, R, A = void>R, function (type parameter) A in type WorkPoolConfig<T, E, R, A = void>A>;
Referenced by 1 symbols