```// still with channel subscription.consumeEach ...

# kroto-plus

[marcoferrer]

// still with channel
subscription.consumeEach {
    responseChannel.send(it)
}
//or with flow
subscription.consumeAsFlow().collect {
    responseChannel.send(it)
}