persistent-queue

A bounded FIFO queue whose items are each written to their own index-named file before entering an in-memory TBQueue, and deleted only after being popped, so a restart reloads exactly the enqueued-but-unconsumed items (at-least-once delivery). Items cache their CBOR serialization, and can be drained in byte- and count-bounded batches with an in-flight pin for safe retries. Polymorphic in the base monad via io-classes.