It’s been fun looking at GenStage’s examples and trying to understand what they do and how to glue everything together.
The end result? A lightweight library provides both worker pooling and rate limiting thanks to GenStage.
Check it out: https://github.com/fredwu/opq
I’m still relatively new to Elixir, so if you notice any issues please let me know. Thanks!