rafal
channel.consumeEach { if(it.sth()){ doSth() } else { // stop consuming - break out of consume } }
elizarov