But that never gets executed cause the consumeEach never breaks

consumeEach will cancel coroutine after last element is received by throwing an exception

When does that for loop exit?

When the channel is closed for receive.

Thats not very helpful

What I understood is that code following your

consumeEach

is not getting executed. This would solve that problem. I'm not suggesting anything else.

Consume each is not exiting

I dont have near enough information to answer your question then, so if you know the basics like you say I'm sure you can figure it out with a bit of debugging