如何合并多个PagingData<T> Flow？解决仅返回第二个流数据的问题

直接使用merge合并两个Pager的PagingData Flow会导致仅显示第二个数据源的数据，核心原因是：
PagingData是为单次分页加载设计的一次性数据流，下游订阅者（如PagingDataAdapter）会先后接收两个PagingData实例，但Adapter只会保留最后收到的那个，第一个数据源的内容被覆盖。

根据你的业务需求，选择以下合适的方案：

方案1：顺序展示两个数据源（先加载完第一个再加载第二个） #

用concat替代merge，它会先发射第一个Flow的所有分页数据，完成后再开始发射第二个Flow的数据：

val posts: Flow<PagingData<Key>>
    get() = concat(
        pager1.flow.cachedIn(viewModelScope),
        pager2.flow.cachedIn(viewModelScope)
    )

方案2：自定义PagingSource混合合并数据源（推荐用于复杂排序/混合展示） #

如果需要将两个数据源的数据按自定义规则（如时间排序）混合展示，应创建一个组合式PagingSource，内部统一处理两个数据源的分页逻辑并合并结果：

class CombinedPagingSource(
    private val getLatest: suspend (page: Int, pageSize: Int) -> List<Key>,
    private val getSaved: suspend (page: Int, pageSize: Int) -> List<Key>
) : PagingSource<Int, Key>() {
    override suspend fun load(params: LoadParams<Int>): LoadResult<Int, Key> {
        val currentPage = params.key ?: 1
        return try {
            // 并行获取两个数据源的当前页数据
            val latestData = getLatest(currentPage, params.loadSize)
            val savedData = getSaved(currentPage, params.loadSize)
            
            // 自定义合并逻辑，示例为按时间戳倒序排序
            val combinedData = (latestData + savedData).sortedByDescending { it.timestamp }
            
            // 计算下一页标识，只要任一数据源还有数据就继续分页
            val nextPage = if (latestData.isNotEmpty() || savedData.isNotEmpty()) currentPage + 1 else null
            
            LoadResult.Page(
                data = combinedData,
                prevKey = if (currentPage == 1) null else currentPage - 1,
                nextKey = nextPage
            )
        } catch (e: Exception) {
            LoadResult.Error(e)
        }
    }

    override fun getRefreshKey(state: PagingState<Int, Key>): Int? {
        return state.anchorPosition?.let { anchorPos ->
            state.closestPageToPosition(anchorPos)?.prevKey ?: state.closestPageToPosition(anchorPos)?.nextKey
        }
    }
}

然后在ViewModel中创建单一Pager：

private val combinedPager = Pager(PagingConfig(pageSize = 5)) {
    CombinedPagingSource(
        getLatest = repository::getLatest,
        getSaved = repository::getSaved
    )
}

val posts: Flow<PagingData<Key>>
    get() = combinedPager.flow.cachedIn(viewModelScope)

方案3：简单拼接每页数据（适用于分页节奏一致的场景） #

如果只是想让每页同时包含两个数据源的当前页数据，可使用combine操作符合并两个PagingData：

val posts: Flow<PagingData<Key>>
    get() = combine(
        pager1.flow.cachedIn(viewModelScope),
        pager2.flow.cachedIn(viewModelScope)
    ) { paging1, paging2 ->
        paging1 + paging2
    }

注意：该方案需要两个数据源的分页更新节奏一致，否则会出现数据不同步的情况。

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