I figured out what I wanted, but not how to do it:
- Little chunks of code that take in (a collection of stuff), and produce a (collection of different stuff) – like a map, but not 1:1.
- That all run in coroutines, to make use of all my cores
- That have reasonable capacity constrained channels so as not to blow up with an OOM.
I don’t know if the “collection of stuff” should be a sequence, or a channel, or what.