Skip to content
Effect Days 2026 Get your ticket

PersistedQueue

12 exports Added in v1.0.0 Source

Accessors

make

Added in v1.0.0 Source

Signature

declare function make<A, I, R>(options: {
readonly name: string;
readonly schema: any;
}): Effect<PersistedQueue<A, R>, never, PersistedQueueFactory>

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"

Signature

declare class PersistedQueueError extends {
readonly _tag: "PersistedQueueError";
readonly cause?: unknown;
readonly message: string;
} & YieldableError<this> {
constructor(...args: [props: {
readonly _tag?: "PersistedQueueError";
readonly cause?: unknown;
readonly message: string;
}, options?: MakeOptions]);
readonly "~@effect/experimental/PersistedQueue/PersistedQueueError": "~@effect/experimental/PersistedQueue/PersistedQueueError";
}

Factory

layer

Added in v1.0.0 Source

Signature

declare const layer: Layer.Layer<PersistedQueueFactory, never, PersistedQueueStore>

makeFactory

Added in v1.0.0 Source

Signature

declare const makeFactory: Effect<any, unknown, unknown>

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

Signature

declare const layerStoreMemory: Layer.Layer<PersistedQueueStore>

Signature

declare class PersistedQueueStore extends any {
constructor();
}

Type IDs

TypeId

Added in v1.0.0 Source

Signature

declare const TypeId: TypeId

TypeId type

Added in v1.0.0 Source

Signature

type TypeId = "~@effect/experimental/PersistedQueue"