面试题：Kotlin中协程与Flow集成的操作符应用

Question

在Kotlin的协程与Flow集成应用中，如何使用flatMapConcat操作符将一个Flow中的每个元素转换为另一个Flow，并按顺序合并它们？请给出具体代码示例，并解释代码逻辑。

Answer 1

代码示例

import kotlinx.coroutines.flow.Flow
import kotlinx.coroutines.flow.flow
import kotlinx.coroutines.flow.flatMapConcat

fun main() = runBlocking<Unit> {
    val outerFlow: Flow<Int> = flow {
        emit(1)
        emit(2)
        emit(3)
    }

    val resultFlow: Flow<String> = outerFlow.flatMapConcat { value ->
        flow {
            emit("$value - A")
            emit("$value - B")
        }
    }

    resultFlow.collect {
        println(it)
    }
}

代码逻辑解释

1. 定义outerFlow:
   • 使用flow构建器创建一个Flow，它会依次发射1、2、3。这个Flow代表外层的数据流。
2. **使用flatMapConcat转换`:
   • outerFlow.flatMapConcat操作符会遍历outerFlow发射的每个元素。
   • 对于outerFlow发射的每个元素value，会创建一个新的Flow，这里新的Flow会发射"$value - A"和"$value - B"。
   • flatMapConcat操作符会按顺序合并这些新创建的Flow。也就是说，只有当前一个新创建的Flow完成发射后，才会处理下一个新创建的Flow。
3. 收集结果:
   • 使用collect函数收集resultFlow发射的所有元素，并打印出来。这样就实现了将outerFlow中的每个元素转换为另一个Flow，并按顺序合并它们的功能。