Just found your library and perused the code - its exactly what I was looking for. One thing I didn't see was the ability to control how many consumers can consume a queue. Essentially, ensuring at most N activeWorkers for a queue (stream).
Just found your library and perused the code - its exactly what I was looking for.
One thing I didn't see was the ability to control how many consumers can consume a queue.
Essentially, ensuring at most N activeWorkers for a queue (stream).