<@U2AEHNFUK> You could maybe look into `produce { ...

# coroutines

[dave08]

@sailxjx You could maybe look into produce { }, you can give it a buffer size, and when full, it will suspend the message requesting until its consumer is ready to receive more, so all you need is a simple consumeEach{} on the producer to process the messages...