Flow转StateFlow用于DataBinding时，如何响应对象属性变化？

StateFlow的核心特性是仅当值的引用发生变化时才会发射新值，所以直接映射可变类的Flow时，属性修改不会触发更新。以下是几种实用的解决思路：

1. 将可变类改为数据类，通过copy生成新实例 #

如果可以修改原类的定义，把普通类改成data class。数据类的copy()方法会创建新的对象实例，改变引用，从而触发StateFlow的发射。

示例：

// 原可变类 -> 修改为数据类
data class User(var name: String, var age: Int)

// 使用时，修改属性通过copy生成新对象
fun updateUserName(user: User, newName: String): User {
    return user.copy(name = newName)
}

// 映射Flow时，只要对象引用变化就会触发更新
val userFlow: Flow<User> = ...
val mappedStateFlow = userFlow.map { user ->
    "当前用户名：${user.name}"
}.stateIn(viewModelScope, SharingStarted.WhileSubscribed(), "")

2. 给可变类添加属性变化监听，转换为Flow #

如果无法修改原类，或者不想改成数据类，可以给可变类的属性添加回调监听，将属性变化事件转换成Flow，再和原对象Flow结合触发重新映射。

方法A：利用Android Data Binding的Observable机制 #

让可变类继承BaseObservable，属性用@Bindable标注，在setter中通知属性变化，再将监听转换为Flow：

import androidx.databinding.BaseObservable
import androidx.databinding.Bindable
import com.yourpackage.BR // 自动生成的BR类

class User : BaseObservable() {
    @get:Bindable
    var name: String = ""
        set(value) {
            field = value
            notifyPropertyChanged(BR.name) // 通知属性变化
        }
}

// 将User的name属性变化转换为Flow
fun User.toNameChangeFlow(): Flow<String> = callbackFlow {
    val callback = object : Observable.OnPropertyChangedCallback() {
        override fun onPropertyChanged(sender: Observable?, propertyId: Int) {
            if (propertyId == BR.name) {
                trySend(name)
            }
        }
    }
    addOnPropertyChangedCallback(callback)
    awaitClose { removeOnPropertyChangedCallback(callback) }
}

// 结合原Flow，触发映射更新
val userFlow: Flow<User> = ...
val userNameStateFlow = userFlow.flatMapLatest { user ->
    user.toNameChangeFlow().map { "用户名更新为：$it" }
}.stateIn(viewModelScope, SharingStarted.WhileSubscribed(), "")

方法B：自定义属性回调 #

如果不想依赖Data Binding的Observable，可以手动给类添加回调接口：

class User {
    var name: String = ""
        set(value) {
            field = value
            nameChangeListener?.invoke(value)
        }
    
    var nameChangeListener: ((String) -> Unit)? = null
}

// 转换为Flow
fun User.nameChanges(): Flow<String> = callbackFlow {
    val listener = { newName: String -> trySend(newName) }
    nameChangeListener = listener
    awaitClose { nameChangeListener = null }
}

// 同样结合原Flow使用
val mappedStateFlow = userFlow.flatMapLatest { user ->
    user.nameChanges().map { /* 生成你需要的UI状态 */ }
}.stateIn(...)

3. 手动维护MutableStateFlow，主动更新值 #

在ViewModel中直接维护一个MutableStateFlow，当可变对象的属性变化时，手动更新StateFlow的值。这种方式更直接，适合简单场景：

class MyViewModel : ViewModel() {
    private val _uiState = MutableStateFlow(UiState(userName = ""))
    val uiState: StateFlow<UiState> = _uiState

    // 假设已持有可变的User对象
    private val user = User()

    init {
        // 监听user的属性变化，主动更新StateFlow
        user.nameChangeListener = { newName ->
            _uiState.value = _uiState.value.copy(userName = newName)
        }
    }

    // 外部调用修改属性的方法
    fun updateUserName(newName: String) {
        user.name = newName
    }
}

// UI状态类（建议用数据类）
data class UiState(val userName: String)

4. 使用Kotlin的Delegated Properties（可选） #

可以用Delegates.observable来监听属性变化，简化回调逻辑：

class User {
    var name: String by Delegates.observable("") { _, _, newValue ->
        nameChangeListener?.invoke(newValue)
    }
    
    var nameChangeListener: ((String) -> Unit)? = null
}

后续的Flow转换和结合方式和方案2一致。

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