Fork me on GitHub

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:

Ben Sless19:03:41

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

Ben Sless19:03:41

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.

Ben Sless07:03:06

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