PersistedQueue
Accessors
Errors
ErrorTypeId
Added in v1.0.0
Source
Signature
declare const ErrorTypeId: ErrorTypeIdErrorTypeId 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 { 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
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();}