You can break this problem in two: one is mapping async operations on a collection. A good tool for that is pipeline-async

the other is rate limiting a "stream" of messages. Imagine you had a process which takes messages from one channel, passes them to another, but doesn't do it faster than some rate? how would you implement it?

Thanks for the tips, I’ll see if I can figure those out.

If you can't, tag me, we'll explore this idea a bit