MutableLiveData连续设置相同值时如何触发Observer回调

ViewModel层相关实现代码如下：

class MainViewModel : ViewModel(){
    private val _text = MutableLiveData<String>()
    val text get() = _text.distinctUntilChanged()

    fun setToA(){ 
      _text.value = "A"
    } 
    fun setToB(){ 
      _text.value = "B"
    } 
}

Fragment中对text字段的观察逻辑实现如下：

//in Fragment
btnA.setOnClickListener {
    mainviewmodel.setToA()
}

btnB.setOnClickListener {
    mainviewmodel.setToB()
}
    
mainviewmodel.text.observe(viewLifecycleOwner){
        //TODO
}

实际场景中存在连续两次点击btnA的情况，会连续调用setValue传入相同的"A"值。当前observer仅在text取值发生变化（A切B、B切A）时才会触发回调，连续传入相同值时不触发。需要实现：每次调用setValue设置text值时，无论传入值是否和当前值相同，都能触发observer回调。

问题根源有两点：

• 链式调用的distinctUntilChanged()会主动过滤连续重复的相同值，阻断分发
• 原生MutableLiveData内置校验逻辑：传入值和当前持有值equals结果为true时，不会触发观察者回调

根据使用场景选以下任意一种方案即可：

方案1：自定义支持重复值分发的LiveData（适合数据状态类场景） #

重写LiveData的分发逻辑，绕开原生的值相等校验，每次setValue都强制触发回调：

class RepeatableMutableLiveData<T> : MutableLiveData<T>() {
    private var currentVersion = 0

    override fun setValue(value: T) {
        currentVersion++
        super.setValue(value)
    }

    override fun postValue(value: T) {
        currentVersion++
        super.postValue(value)
    }

    override fun observe(owner: LifecycleOwner, observer: Observer<in T>) {
        super.observe(owner, object : Observer<T> {
            private var observerVersion = currentVersion
            override fun onChanged(value: T) {
                if (observerVersion != currentVersion) {
                    observerVersion = currentVersion
                    observer.onChanged(value)
                }
            }
        })
    }
}

替换ViewModel中原有实现即可，注意移除distinctUntilChanged()调用：

class MainViewModel : ViewModel(){
    private val _text = RepeatableMutableLiveData<String>()
    val text: LiveData<String> get() = _text

    fun setToA(){ 
      _text.value = "A"
    } 
    fun setToB(){ 
      _text.value = "B"
    } 
}

原有Fragment的观察逻辑不需要修改，每次调用setValue都会正常触发回调。

方案2：事件包装类（适合点击触发的一次性事件场景） #

如果这个回调是用来响应点击事件（比如弹提示、页面跳转），可以用通用事件包装类，每次设置值时生成新的包装对象，绕开值相等判断：

class Event<out T>(private val content: T) {
    private var consumed = false

    // 可选：需要处理屏幕旋转等配置变更后不重复触发事件时用这个方法取内容
    fun getContentIfNotConsumed(): T? {
        return if (consumed) null else {
            consumed = true
            content
        }
    }

    // 需要每次setValue都触发，不管之前是否处理过，直接取这个内容
    fun getContent(): T = content
}

对应调整ViewModel实现：

class MainViewModel : ViewModel(){
    private val _text = MutableLiveData<Event<String>>()
    val text: LiveData<Event<String>> get() = _text

    fun setToA(){ 
      _text.value = Event("A")
    } 
    fun setToB(){ 
      _text.value = Event("B")
    } 
}

Fragment观察逻辑稍作调整即可：

mainviewmodel.text.observe(viewLifecycleOwner){
    val value = it.getContent()
    // TODO 业务逻辑
}

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