Skip to main content
Module

x/kvmq/mod.ts>Queue#listenUpdates

Library inspired by BullMQ for Deno
Latest
method Queue.prototype.listenUpdates
import { Queue } from "https://deno.land/x/kvmq@v0.3.0/mod.ts";

Listens for queue updates.

Note: currently it just polls the queue every few seconds.

Parameters

onUpdate: (jobs: Array<JobEntry<State>>) => void
options: { signal?: AbortSignal; pollIntervalMs?: number; }

Returns

Promise<void>