Рассмотрим следующий код:
import kotlinx.coroutines.channels.Channel
import kotlinx.coroutines.*
fun main() = runBlocking<Unit> {
val channel = Channel<String>()
launch {
channel.send("A1")
channel.send("A2")
log("A done")
}
launch {
channel.send("B1")
log("B done")
}
launch {
for (x in channel) {
log(x)
}
}
}
fun log(message: Any?) {
println("[${Thread.currentThread().name}] $message")
}
Исходная версия имеет такую сопрограмму-получатель:
launch {
repeat(3) {
val x = channel.receive()
log(x)
}
}
Она ожидает только 3 сообщения в канале. Если я изменю его на первую версию, мне нужно закрыть канал после того, как все сопрограммы производителя будут выполнены. Как я могу это сделать?