I have an outgoing message channel, and an incomin...

# coroutines

[reactormonk]

I have an outgoing message channel, and an incoming message channel - most incoming message are associated with an outgoing message, but not all. Sometimes I'll have to also retry, and I'll also have to apply some throttling. Are there primitives / libraries out there, or should I go implement some queues on my own?

[franztesca]

All the utility functions to achieve this are on the Flow interface. You can use a receive Channel as a flow using Channel.consumeAsFlow().