Skip to main content Link Search Menu Expand Document (external link)
effect

AtLeastOnce overview

Added in v1.0.0

Table of contents

constructors

atLeastOnceRecipientBehaviour

Signature

export declare const atLeastOnceRecipientBehaviour: <Msg, R>(
  fa: RecipientBehaviour.RecipientBehaviour<Msg, R>
) => RecipientBehaviour.RecipientBehaviour<Msg, R | AtLeastOnceStorage.AtLeastOnceStorage>

Added in v1.0.0

utils

runPendingMessageSweeperScoped

Signature

export declare const runPendingMessageSweeperScoped: (
  interval: Duration.Duration
) => Effect.Effect<void, never, AtLeastOnceStorage.AtLeastOnceStorage | Sharding.Sharding | Scope.Scope>

Added in v1.0.0