“合并”数据或“设置”数据，MediatorLiveData

Question

文档(https://developer.android.com/reference/androidx/lifecycle/MediatorLiveData)谈到了合并数据...但是这个函数显然是在设置它。

当我想到“合并”时，我会想到.add()或.put()，或者.set(X x，Y y)，..我可以将两个对象捆绑在一个对象中，或者是一个对象列表，或者一个对象数组。

但是函数说的是.setValue()，文档说的是merge

​

​

日志给我的印象是前两个setValue()被完全忽略了：

​

​

因此，与其是：

   ViewModel: onChnaged: [Folder1, Folder2, Folder3]
   Fragment: onChanged: Folder1 ...etc
   ViewModel: onChanged: []
   Fragment: onChanged:
   ViewModel: onChanged: [Quantity1, Quantity2, Quantity3]
   Fragment: onChanged: Quantity1 ...etc

只有第一个.setValue(文件夹)显示在片段上，我猜这只是因为它花费了3个查询中最长的时间来解决。

​

​

……

​

​

因此，如果我误解了合并的概念，我需要做一个带有Diff.Util的LiveData/MutableLiveData>来管理传入的列表或单个对象，还需要一个信号量来处理异步时间(？也许？)...add()和.replace()会相应地执行函数，等等，但是这样我就可以使用任何LiveData，而不是MediatorLiveData<>。

有什么我可以用的吗？

我遗漏了什么？

最糟糕的是，如果MediatorLiveData做了我认为它做的事情，那么在正确处理其生命周期的同时将多个LiveDatas连接到一个观察者并不是那么困难……这有什么意义。

我看到一些使用.combine(data1，data2)的Kotlin示例，但是这个函数根本不存在。

Answer 1

这个答案是用kotlin写的，希望你能理解，或者有人能翻译成java。我有这个扩展，它恰好将3个livedata源合并到一个对象中。

扩展名：

fun <T, A, B, C> LiveData<A>.combineAndCompute3(
    other1: LiveData<B>,
    other2: LiveData<C>,
    onChange: (A, B?, C?) -> T
): LiveData<T> {

    var source0emitted = false
    var source1emitted = false
    var source2emitted = false

    val result = MediatorLiveData<T>()

    val mergeF = {
        val source0Value = this.value
        val source1Value = other1.value
        val source2Value = other2.value

        if (source0emitted && source1emitted && source2emitted) {
            result.value = onChange.invoke(source0Value!!, source1Value, source2Value)
        }
    }

    result.addSource(this) { source0emitted = true; mergeF.invoke() }
    result.addSource(other1) { source1emitted = true; mergeF.invoke() }
    result.addSource(other2) { source2emitted = true; mergeF.invoke() }

    return result
}

在我的视图模型中，我有这样的模型：

    private val _id = MutableLiveData<Int>()
    private val id = _id.distinctUntilChanged()

    private val _name = MutableLiveData<String?>()
    private val name = _name.distinctUntilChanged()

    private val _load = MutableLiveData<Boolean>()
    private val load = _load.distinctUntilChanged()


    private val detailLoad = id.combineAndCompute3(name, load) {
        A, B, C -> DetailLoad(A, B, C)
    }

DetailLoad是一个常规的数据类，A是一个整数，B是一个字符串，C是一个布尔值，我以一种非常标准的方式postValue到我的mutablelivedatas中。