Skip to content

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 any {
  constructor();
  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";