使用 Transformations.map 而不是 observeForever [重复]

Question

我正在做我的第一次实习，我正在一个项目中将 RX 代码转换为 LiveData。 在某些时候，我不得不在某些存储库中用 observeForever() + Globalscope(Dispatchers.Main) 替换 subscribe() 函数，但显然使用 observeForever() 并不是最好的事情，我的实习导师建议我使用 Transformations.map () 代替。

我不确定如何在以下代码中使用 map() 而不是 observeForever（在存储库中）：

        //I am using Globalscope with Dispathers.Main otherwise I get "cannot observeForever in a background Thread error
        GlobalScope.launch(Dispatchers.Main){
            someBooleanLiveData.observeForever { 
                if (it) {
                    // DO SOMETHING
                } else {
                    // DO SOMETHING ELSE
                }
            }
        }

我从 Transformations.map() 函数中了解到的是，它用于映射给定 LiveData 对象的值，就像 ReactiveX 的 Map operator 一样

我试过了，但似乎没有做我想做的事：

        Transformations.map(someBooleanLiveData){
            if (it) {
                // DO SOMETHING
            } else {
                // DO SOMETHING ELSE
            }
        }

我的问题是我应该如何使用 Transformation.map() 来避免 observeForever ？

做某事：如果您需要示例，可能是 livedataObject.postValue(it)

提前感谢您的回复。

Answer 1

Transformations.map 旨在用于转换观察到的每个元素。所以它没有一个有条件的方法来防止排放。举例：

Transformations.map(booleanLiveData) {
    if (it) 1 else 0
}

返回一个LiveData<Int>

如果您想添加使实时数据仅在某些时候发出的条件，那么您必须使用MediatorLiveData

class MyMediator : MediatorLiveData<SomeType>() {


    //we can create this wrapper method for convenience    
    fun addBooleanSource(booleanLiveData: LiveData<Boolean>) {
        //this method is already exposed and you can wrap it or do it in the invoker
        addSource(booleanLiveData) {
           if (it) {
                value = //do something
           }
        }
    }
     
}

诀窍在于MediatorLiveData 可以将value 作为字段访问，因此您可以选择何时更新它，何时不更新，还可以在此过程中应用转换。

以您需要的方式使用它：

        private val _myMediator = MyMediator()
        val myMediator: LiveData<YourType>
            get() = _myMediator

        GlobalScope.launch(Dispatchers.Main){
            _myMediator.addBooleanSource(someBooleanLiveData)
        }

然后观察myMediator