PersistedQueue
Accessors
Errors
ErrorTypeId
Added in v1.0.0
Source
Signature
declare const ErrorTypeId: ErrorTypeId;ErrorTypeId type
Added in v1.0.0
Source
Signature
type ErrorTypeId = "~@effect/experimental/PersistedQueue/PersistedQueueError";PersistedQueueError
Added in v1.0.0
Source
Signature
declare class PersistedQueueError extends any {
constructor();
readonly "~@effect/experimental/PersistedQueue/PersistedQueueError": "~@effect/experimental/PersistedQueue/PersistedQueueError";
}Factory
Signature
declare const layer: Layer.Layer<PersistedQueueFactory, never, PersistedQueueStore>;makeFactory
Added in v1.0.0
Source
Signature
declare const makeFactory: Effect<any, unknown, unknown>;PersistedQueueFactory
Added in v1.0.0
Source
Signature
declare class PersistedQueueFactory extends any {
constructor();
}Models
PersistedQueue interface
Added in v1.0.0
Source
Signature
interface PersistedQueue<in out A, out R = never> {
readonly "~@effect/experimental/PersistedQueue": "~@effect/experimental/PersistedQueue";
readonly offer: (
value: A,
options?: {
readonly id: string | undefined;
},
) => Effect<string, any, R>;
readonly take: <XA, XE, XR>(
f: (
value: A,
metadata: {
readonly attempts: number;
readonly id: string;
},
) => Effect<XA, XE, XR>,
options?: {
readonly maxAttempts?: number;
},
) => Effect<XA, any, R | XR>;
}Store
layerStoreMemory
Added in v1.0.0
Source
Signature
declare const layerStoreMemory: Layer.Layer<PersistedQueueStore>;PersistedQueueStore
Added in v1.0.0
Source
Signature
declare class PersistedQueueStore extends any {
constructor();
}