Skip to main content
Module

x/fathym_common/src/deno-kv/listenQueueAtomic.ts>listenQueueAtomic

The Fathym Reference Architecture provides the common foundation for applications built in Typescript.
fathym-deno/reference-architecture
Go to Latest
function listenQueueAtomic
import { listenQueueAtomic } from "https://deno.land/x/fathym_common@v0.2.22-integration/src/deno-kv/listenQueueAtomic.ts";

Listen for a message in the queue and apply the atomic operation handler.

Parameters

queueKv: Deno.Kv

The queue Deno.Kv instance.

msg: DenoKVNonce

The message with nonce and versionstamp.

atomicOpHandler: AtomicOperationHandler

The atomic operation handler.

optional
opKv: Deno.Kv

(optional) The operation Deno.Kv instance.

Returns

Promise<Deno.KvCommitResult | Deno.KvCommitError>

A Deno.KvCommitResult or Deno.KvCommitError based on the atomic operation handler.