Various small utilities

Mixin for Collectable implementation in blocking collections

Mixin for Enumerable implementation in blocking collections

A queue hosted in a process so that other processes can access it concurrently. It implements the BlockingCollection protocol. Enumerating a BlockingQueue will consumes it content. Enumeration only complete when the BlockingQueue is empty and BlockingQueue.complete/1 has been called on the BlockingQueue

State for the blocking queue

A simple countdown latch implementation useful for simple fan in scenarios. It is initialized with a count and clients can wait on it to be signaled when the count reaches 0, decrement the count or increment the count

A simple semaphore implementation, useful when you need quick control around resource access and do not want to resort to the full OTP artillery or complex process pooling

Interface to a blocking collection

A generic interface for “waitable” objects