tidyq

A tiny queue with backpressure, retries, and nothing else.

Install

bun add tidyq

import { queue } from 'tidyq'

const q = queue({ concurrency: 4, retries: 2 })

for (const job of jobs) q.push(() => process(job))
await q.drain()

queue(opts) — create a queue. concurrency (default 1), retries (default 0).
q.push(fn) — enqueue a task returning a promise.
q.drain() — resolves when the queue is empty.

MIT