PageKeyedDataSource下拉刷新总是调用loadInitial，Paging库不支持增量刷新？

我明白你在使用PagingWithNetworkSample时遇到的痛点——每次下拉刷新调用invalidate()都会触发loadInitial重新下载全部初始数据，没法带着上次的key只拉取新增条目。其实这个场景是可以实现的，只是需要调整DataSource的实现逻辑，而不是直接依赖默认的invalidate()行为。

下面是具体的实现思路和代码示例：

核心思路 #

默认情况下，invalidate()会让当前DataSource失效，Factory会创建一个全新的DataSource，而新DataSource的loadInitial会从初始位置（比如page 0）开始加载，所以每次刷新都会重复下载初始数据。我们需要做的是：

• 让DataSource能记住上次刷新时的「最新条目标识」（比如最新条目的ID、时间戳）
• 刷新时把这个标识传递给新创建的DataSource，让loadInitial带着这个标识去请求新增数据
• 根据后端返回的结果，决定是添加新条目还是直接结束刷新

具体实现步骤 #

1. 自定义带刷新Key的DataSource #

我们以PageKeyedDataSource为例（和Sample里的类型一致），添加一个refreshKey变量来存储上次的最新条目标识，在loadInitial里根据这个Key来请求数据：

class CustomPageDataSource(private val api: YourApiService) : PageKeyedDataSource<Int, Item>() {
    // 存储上次刷新时的最新条目ID，用来请求新增数据
    var refreshKey: Int? = null

    override fun loadInitial(
        params: LoadInitialParams<Int>,
        callback: LoadInitialCallback<Int, Item>
    ) {
        // 如果有刷新Key，就用它作为起始点请求新增数据；否则从初始位置加载
        val startKey = refreshKey ?: 0
        val response = api.fetchItems(startKey, params.requestedLoadSize).execute()
        val newItems = response.body() ?: emptyList()

        // 处理返回结果：如果是刷新且有新条目，把新条目加到现有列表前面
        // 这里需要根据后端接口的逻辑调整，比如后端返回的是比refreshKey更新的条目
        if (refreshKey != null && newItems.isNotEmpty()) {
            // 假设后端返回的是按时间倒序的新条目，直接传递给callback即可
            callback.onResult(newItems, startKey - params.requestedLoadSize, startKey + params.requestedLoadSize)
        } else {
            // 首次加载或者没有新条目，正常返回数据
            callback.onResult(newItems, null, startKey + params.requestedLoadSize)
        }

        // 更新refreshKey为当前最新的条目ID，供下次刷新使用
        refreshKey = newItems.firstOrNull()?.id
    }

    override fun loadBefore(params: LoadParams<Int>, callback: LoadCallback<Int, Item>) {
        // 实现加载更早数据的逻辑（如果需要）
    }

    override fun loadAfter(params: LoadParams<Int>, callback: LoadCallback<Int, Item>) {
        // 实现加载更多后续数据的逻辑（和Sample一致即可）
        val response = api.fetchItems(params.key, params.requestedLoadSize).execute()
        val items = response.body() ?: emptyList()
        callback.onResult(items, params.key + params.requestedLoadSize)
    }
}

2. 实现带刷新Key控制的DataSource.Factory #

我们需要一个Factory来管理DataSource的创建，并且能传递刷新Key给新的DataSource：

class CustomDataSourceFactory(private val api: YourApiService) : DataSource.Factory<Int, Item>() {
    private val _currentDataSource = MutableLiveData<CustomPageDataSource>()
    val currentDataSource: LiveData<CustomPageDataSource> = _currentDataSource

    // 设置刷新Key，供新创建的DataSource使用
    fun setRefreshKey(key: Int?) {
        _currentDataSource.value?.refreshKey = key
    }

    override fun create(): DataSource<Int, Item> {
        val dataSource = CustomPageDataSource(api)
        _currentDataSource.postValue(dataSource)
        return dataSource
    }
}

3. 在ViewModel中实现刷新逻辑 #

在ViewModel里，我们需要处理刷新请求：先让旧DataSource失效，然后给新DataSource传递刷新Key：

class YourViewModel(private val api: YourApiService) : ViewModel() {
    private val dataSourceFactory = CustomDataSourceFactory(api)
    val pagedList = LivePagedListBuilder(
        dataSourceFactory,
        PagedList.Config.Builder()
            .setPageSize(20)
            .setEnablePlaceholders(false)
            .build()
    ).build()

    fun triggerRefresh() {
        // 获取当前DataSource的最新refreshKey
        val latestKey = dataSourceFactory.currentDataSource.value?.refreshKey
        // 让旧DataSource失效，触发Factory创建新的DataSource
        dataSourceFactory.currentDataSource.value?.invalidate()
        // 给新创建的DataSource设置refreshKey
        dataSourceFactory.setRefreshKey(latestKey)
    }
}

4. 关联下拉刷新控件 #

最后在Activity/Fragment里，把下拉刷新的监听和ViewModel的刷新方法绑定：

swipeRefreshLayout.setOnRefreshListener {
    viewModel.triggerRefresh()
    // 可以根据PagedList的加载状态来控制刷新动画，这里简单处理
    swipeRefreshLayout.isRefreshing = false
}

额外说明 #

• 这个方案依赖后端接口支持「根据最新条目标识返回新增数据」的功能，如果后端不支持，你可能需要结合本地缓存（比如Room）：刷新时先请求最新数据，和本地缓存对比，只更新差异部分，再同步到PagedList。
• 如果你的DataSource是ItemKeyedDataSource或者PositionalDataSource，逻辑类似，只需要调整loadInitial里的参数传递方式即可。

这样调整后，每次下拉刷新就只会请求新增的条目，而不会重复下载全部初始数据了。

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