API Reference queutils v1.2.1

Handy little queues and producers.

A GenStage producer that acts as a blocking queue, with a fixed length. Blocks any time Queutils.BlockingProducer.push/2 is called when the queue is at its maximum length.

A queue with a fixed length that blocks on Queutils.BlockingQueue.push/2 if the queue is full.

A GenStage producer that polls a Queutils.BlockingQueue at a fixed interval, emitting any events on the queue.