Android中Flow+Room多日期查询如何合并多个返回Flow列表

问题根源 #

• Room返回Flow类型的DAO方法不需要加suspend修饰：suspend用于单次异步查询，返回Flow的可观察查询底层已经处理了异步逻辑，加suspend属于多余且不符合规范的写法。
• 原有代码仅将多个Flow实例打包成列表发射，没有合并各个Flow发射的数据内容，导致返回类型嵌套多层不符合要求。

代码实现 #

第一步：修正DAO方法 #

@Transaction
@Query("select * from expenses where date= :date")
// 移除suspend修饰符
fun getExpenseWithTagByDate(date: LocalDate): Flow<List<ExpenseWithTag>>

第二步：合并多日期查询Flow #

使用Kotlin协程标准库的combine操作符合并多个Flow的观测结果，直接返回统一的可观察数据：

import kotlinx.coroutines.flow.combine
import kotlinx.coroutines.flow.flowOf
import kotlinx.coroutines.flow.flowOn

fun getExpenseWithTagByMonth(dates: List<LocalDate>): Flow<List<ExpenseWithTag>> {
    // 空日期边界处理
    if (dates.isEmpty()) return flowOf(emptyList())
    
    // 生成每个日期对应的查询Flow列表
    val dayFlows = dates.map { expenseDao.getExpenseWithTagByDate(it) }
    
    // 合并所有Flow的最新结果，压平为统一的消费列表
    return dayFlows.combine { dayResults ->
        // 如果需要按日期/时间排序，可在flatten后加sortedBy逻辑
        dayResults.flatten()
    }.flowOn(Dispatchers.IO)
}

使用方式 #

原有调用逻辑完全兼容，此时getExpenseWithTagByMonth(dates).asLiveData()得到的返回类型就是LiveData<List<ExpenseWithTag>>，直接观测使用即可。

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