kotlin flow 合并三个流 实例代码
时间: 2023-11-18 10:02:23 浏览: 152
kotlin实例
好的,以下是示例代码:
```kotlin
import kotlinx.coroutines.delay
import kotlinx.coroutines.flow.*
import kotlinx.coroutines.runBlocking
fun main() {
val flow1 = (1..5).asFlow().onEach { delay(100) }
val flow2 = (6..10).asFlow().onEach { delay(200) }
val flow3 = (11..15).asFlow().onEach { delay(300) }
runBlocking {
merge(flow1, flow2, flow3)
.collect { println(it) }
}
}
```
在这个示例中,我们创建了三个包含数字序列的 `Flow`,每个 `Flow` 中间使用 `delay` 函数模拟了一些耗时操作。然后,我们使用 `merge` 函数将这三个 `Flow` 合并成一个,最后遍历它并打印出它的每个元素。
阅读全文