每次其他 LiveData 更新其值时，都会更新 LiveData 的值

Question

我有一个包含如下列表的LiveData：

val originalSourceLiveaData = MutableLiveData<List<SomeType>>()

现在我有另一个LiveData它应该指示originalSourceLiveaData值的过滤。

val filterLiveData = MutableLiveData<String>()

我想要的是，每次其中任何一个LiveData更改值时，都应该更新结果列表。我尝试做这样的事情：

val filteredListLiveData = MediatorLiveData<List<SomeType>().apply {
    addSource(originalSourceLiveaData) { this.value = filteringMethod() }
    addSource(filterLiveData) { this.value = filteringMethod() }
}

这很好用，但我想知道是否有更好的解决方案。

我的问题是，如果添加了另一个 LiveData，我将不得不将其添加为源，如下所示：

val filteredListLiveData = MediatorLiveData<List<SomeType>().apply {
    addSource(originalSourceLiveaData) { this.value = filteringMethod() }
    addSource(filterLiveData) { this.value = filteringMethod() }
    addSource(anotherSourceLiveData) { 
        this.value = filteringMethod() // this feels like a duplicate 
    }
}

有什么改进的想法吗？提前感谢！

Answer 1

您可以使用 Kotlin 的扩展函数特性使其更具响应式风格。

假设您具有相同类型的T的firstLiveaData和secondLiveData。现在，您要先过滤它们，然后再侦听它们的所有更改。

因此，您可以添加以下扩展函数：

• filter函数将根据给定的谓词函数过滤您的实时数据
• addSources函数将执行添加多个实时数据并侦听其更改的样板文件

fun <T> LiveData<T>.filter(predicate : (T) -> Boolean): LiveData<T> {
    val mutableLiveData = MediatorLiveData<T>()
    mutableLiveData.addSource(this) {
        if(predicate(it))
            mutableLiveData.value = it
    }
    return mutableLiveData
}
fun <T> MediatorLiveData<T>.addSources(vararg listOfLiveData: LiveData<T>, callback: (T) -> Unit) {
    listOfLiveData.forEach {
        addSource(it, callback)
    }
}

此外，您可以使用merge函数将多个具有相同类型的LivaData对象合并为一个：

fun <T> merge(vararg liveDataList: LiveData<T>): LiveData<T> {
    val mergedLiveData = MediatorLiveData<T>()
    liveDataList.forEach { liveData ->
        liveData.value?.let {
            mergedLiveData.value = it
        }
        mergedLiveData.addSource(liveData) { source ->
            mergedLiveData.value = source
        }
    }
    return mergedLiveData
}

下面是一个示例：

fun doSomething() {
    val firstLiveData = MutableLiveData<List<SomeType>>()
    val secondLiveData = MutableLiveData<List<SomeType>>()
    merge(firstLiveData, secondLiveData).filter { someFilterFunction() }.observe(...)
}

如果您有不同类型的LiveData(例如 firstLiveData<Int>和secondLiveData<String>(，您可以简单地添加一个map扩展函数。