如上所述,我想按顺序连接两个流,因此merge
不起作用.
示例:
val f1 = flowOf(1, 2)
val f2 = flowOf(3, 4)
val f = concatenate(f1, f2) // emits 1, 2, 3, 4
如上所述,我想按顺序连接两个流,因此merge
不起作用.
示例:
val f1 = flowOf(1, 2)
val f2 = flowOf(3, 4)
val f = concatenate(f1, f2) // emits 1, 2, 3, 4
您可以使用flattenConcat
:
fun <T> concatenate(vararg flows: Flow<T>) =
flowOf(*flows).flattenConcat()
或flow
建筑商:
fun <T> concatenate(vararg flows: Flow<T>) = flow {
for (flow in flows) {
emitAll(flow)
}
}