I think you have two options. you can `consumeEach...

# kroto-plus

[marcoferrer]

I think you have two options. you can consumeEach on the channel and forward to the response channel or subscription.consumeAsFlow().collect{ responseChannel.send(it) }