Clojurians Log v2

I’m trying to use core async for a project but I clearly don’t understand it well. I’ve posted a detailed question here: https://stackoverflow.com/q/66500942/1395149

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.