Kotlin中如何将Flow<List<T>>转换为Flow<T>？

问题原因 #

你编写的代码无法生效有两个核心问题：

• onEach 是仅执行副作用的操作符，不会向下游发射新元素，你在内层创建的flow { emit(it) } 没有被主动订阅，内部的发射逻辑根本不会执行。
• 对List调用onEach仅会遍历列表元素，不会完成数据流的结构转换，最终返回的还是原List类型，无法产生符合预期的数据流元素。

正确实现 #

你只需要先把每次上游发射的List<T>转换为逐个发射内部元素的Flow<T>，再把嵌套的Flow结构展平即可，常用实现方案如下：

方案1：使用 flatMapConcat（适配绝大多数场景推荐） #

val targetFlow: Flow<T> = outerFlow.flatMapConcat { list ->
    list.asFlow()
}

flatMapConcat 会按上游发射List的顺序逐个处理，前一个List的所有元素全部发射完成后，才会处理下一个上游发射的List，元素顺序和上游列表顺序完全一致。

方案2：使用 flatMapLatest（适配仅需处理最新数据场景） #

val targetFlow: Flow<T> = outerFlow.flatMapLatest { list ->
    list.asFlow()
}

如果上游发射了新的List，会立刻取消前一个List还未完成的发射逻辑，直接开始处理最新的List元素，适合旧列表数据不需要再处理的场景。

方案3：使用 flatMapMerge（适配高吞吐量不要求顺序场景） #

val targetFlow: Flow<T> = outerFlow.flatMapMerge { list ->
    list.asFlow()
}

支持同时处理多个上游发射的List，不同List的元素可能会交叉发射，吞吐量更高，适合不严格要求处理效率、可以接受元素顺序打乱的场景。

方案4：先转换为嵌套Flow再展平 #

你也可以先把Flow<List<T>>转换为Flow<Flow<T>>，再调用展平操作符，效果和flatMapConcat完全一致：

val targetFlow: Flow<T> = outerFlow
    .map { it.asFlow() }
    .flattenConcat()

内容的提问来源于stack exchange，提问作者Jan Deinhard