背景

  1. 现有一个StateFlow及其监听
private val stateFlow = MutableStateFlow(kotlin.Pair<String, ArrayList<String>>("abc", ArrayList()))
GlobalScope.launch {    stateFlow.collect {        // do something    }}
  1. 更新ArrayList并尝试emit
GlobalScope.launch {    stateFlow.value.second.add("test")    stateFlow.emit(stateFlow.value)}

实际上，collect并不会被调用

起因

MutableStateFlow真正的实现者是StateFlowImpl, emit办法代码如下:

override suspend fun emit(value: T) {    this.value = value}

查看value的set办法：

public override var value: T    get() = NULL.unbox(_state.value)    set(value) { updateState(null, value ?: NULL) }
private fun updateState(expectedState: Any?, newState: Any): Boolean {    var curSequence = 0    var curSlots: Array<StateFlowSlot?>? = this.slots // benign race, we will not use it    synchronized(this) {        val oldState = _state.value        if (expectedState != null && oldState != expectedState) return false // CAS support        if (oldState == newState) return true // Don't do anything if value is not changing, but CAS -> true        _state.value = newState        curSequence = sequence        ... 省略局部代码    }}

其中"if (oldState == newState) return true"因emit前后是同一个对象，导致条件为true，那么，如果emit前后不是同一个对象，即可解决这个问题？

另一个问题

emit时尝试以下代码:

GlobalScope.launch {    stateFlow.value.apply {        stateFlow.emit(kotlin.Pair(first, second))    }}

实际上，上述代码仍旧不能解决问题，因为kotlin.Pair默认重写了equals办法，查看kotlin.Pair decompiled的Java文件

public final class Pair {    public int hashCode() {        Object var10000 = this.first;        int var1 = (var10000 != null ? var10000.hashCode() : 0) * 31;        Object var10001 = this.second;        return var1 + (var10001 != null ? var10001.hashCode() : 0);    }    public boolean equals(@Nullable Object var1) {        if (this != var1) {            if (var1 instanceof Te.Pair) {                Te.Pair var2 = (Te.Pair) var1;                if (Intrinsics.areEqual(this.first, var2.first) && Intrinsics.areEqual(this.second, var2.second)) {                    return true;                }            }            return false;        } else {            return true;        }    }}

其中Intrinsics.areEqual代码如下:

public static boolean areEqual(Object first, Object second) {    return first == null ? second == null : first.equals(second);}

故即便pair对象自身不一样，但因为kotlin默认重写了equals办法，而pair.first与pair.second是一样的，从而条件"if (oldState == newState) return true"成立

解决办法

因为StateFlow源码无奈批改且是特定场景需要，故无奈将判断条件改为kotlin的"==="；故应用android.util.Pair或者自定义java Pair class即可

论断

kotlin class默认实现了equals办法，判断的是内容相等，而Java的class判断的是地址相等，故判断对象相等时需注意此细节，依据需要来判断地址相等(===)还是内容相等(==)