vaskir
09/23/2018, 1:56 PMcoroutineScope {
val ch = produce {
for (i in 1..30)
send(i)
close()
}
ch.consumeEach {
launch {
print("offering $it...")
queue.offer(it).await()
println("offered $it")
}
}
}