次のようにすると、
0〜9が流れてきている間は collect
が suspend し続け、
10 が流れてきたら collect
が終了して "Finshed"
が出力される。
flow {
var count = 0
while (true) {
emit(count++)
}
}.takeWhile {
it < 10
}.collect {
println(it)
}
println("Finished")
/以上