android - 如何在订阅 liveData 后仅针对新更新观察 liveData

Question

使用PagedList，这里没有数据库备份，而是内存中的数据列表(称其为CachedDataList)，可以通过fetchMore()填充功能。

有了 PositionalDataSource、DataSource.Factory 和 PagedList.BoundaryCallback，它可以工作，但这里有一个问题。

流程是PositionalDataSource的loadInitial()开始会被调用，开始从CachedDataList加载数据，并调用loadRange() 之后继续按页面大小从 CachedDataList 加载数据。

当 CachedDataList 中的所有数据都被分页时，将调用 BoundaryCallback::onItemAtEndLoaded()(如果开始时没有备份数据，则 BoundaryCallback::onZeroItemsLoaded() 被调用)，

在那里它将开始要求 fetchMore 将更多数据附加到 CachedDataList 中，当新数据附加到它时，然后调用 DataSource 的 invalidate() 来重新启动新的 PagedList 和 DataSource 对，并再次从 PositionalDataSource 的 loadInitial() 开始。

由

完成

observableCachedData.observe(owner, refreshHandler!!) 
//??? TODO: how to only listen to newly posted data after 
//starting the observe?  
//DOC: 'If LiveData already has data set, it will be delivered to the observer.'

// fetchMore
val didFetch = dataRequester.fetchMore()  //asyc call

这里，它观察observableCachedData的变化，如果有变化则调用

的onChanged()

class RefreshHandler(val observableCachedData: MutableLiveData<List<Data>>) : Observer<List<Data>> {
override fun onChanged(datalist: List<Data>?)

会被调用，并在其中调用DataSource的invalidate()

但是 observableCachedData.observe() 的订阅会导致立即调用 refreshHandler(这是 DOC 中所述的设计)，这里不需要这种行为，因为我们希望在新数据附加到 CachedDataList 时调用处理程序。

即CachedDataList 有 30 个数据，当执行 fetchMore() 时会有另外 30 个数据附加到它，变成 60。但是这个 onChange() 被调用时数据仍然是 30 (追加尚未到来)。

有没有办法订阅实时数据，但只收到订阅后发生的更新通知？

class DataBoundaryCallback(
        private val owner: LifecycleOwner,
        private val dataRequester: FetchMoreRequester,
        private val dataSourceFactory: DataSourceFactory?
) : PagedList.BoundaryCallback<IData>() {

    private var hasRequestInProgress = false

    override fun onZeroItemsLoaded() {
        requestAndSaveData()
    }

    override fun onItemAtEndLoaded(itemAtEnd: IData) {
        requestAndSaveData()
    }

    private fun requestAndSaveData() {

        if (hasRequestInProgress) return

        hasRequestInProgress = true

        // ask dataRequester to fetchMore
        // setup observer

        val cachedDataList = dataRequester.getCachedLiveData()
        val observableCachedData = cachedDataList.getLiveData()
        refreshHandler = RefreshHandler(observableCachedData)

        observableCachedData.observe(owner, refreshHandler!!) //??? TODO: how to only listen to newly posted data after starting the observe?  DOC: 'If LiveData already has data set, it will be delivered to the observer.'

        // fetchMore
        val didFetch = dataRequester.fetchMore()
        if (!didFetch) {  //not stated fetch
            hasRequestInProgress = false
            observableCachedData.removeObserver(refreshHandler!!)
        }
    }

    var refreshHandler : RefreshHandler? = null
    inner class RefreshHandler(val observableCachedData: MutableLiveData<List<Data>>) : Observer<List<Data>> {
        override fun onChanged(datalist: List<Data>?) {
            observableCachedData.removeObserver(refreshHandler!!)
            val dataSource = dataSourceFactory.getPositionalDataSource()

            // to start a new PagedList and DataSource pair flow
            // and trigger the DataSource's loadInitial()
            dataSource.invalidate()
        }
    }
}

Answer 1

您可以使用 SingleLiveEvent

SingleLiveEvent