PersistedQueue
Accessors
Errors
Since v1.0.0 Source
Signature
declare const ErrorTypeId: ErrorTypeIdErrorTypeId
type Since v1.0.0 Source
Signature
type ErrorTypeId = "~@effect/experimental/PersistedQueue/PersistedQueueError" Since v1.0.0 Source
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
Models
PersistedQueue
interface Since 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>;}