修改列表时，Jetpack composecollectAsState() 未收集热流

Question

当我使用collectAsState()时，collect {}仅在传递新列表时触发，而不是在修改和发出时触发。

查看模型

@HiltViewModel
class MyViewModel @Inject constructor() : ViewModel() {
    val items = MutableSharedFlow<List<DataItem>>()
    private val _items = mutableListOf<DataItem>()

    suspend fun getItems() {
        _items.clear()

        viewModelScope.launch {
            repeat(5) {
                _items.add(DataItem(it.toString(), "Title $it"))
                items.emit(_items)
            }
        }

        viewModelScope.launch {
            delay(3000)
            val newItem = DataItem("999", "For testing!!!!")
            _items[2] = newItem
            items.emit(_items)
            Log.e("ViewModel", "Updated list")
        }
    }
}

data class DataItem(val id: String, val title: String)

可组合项

@Composable
fun TestScreen(myViewModel: MyViewModel) {
    val myItems by myViewModel.items.collectAsState(listOf())

    LaunchedEffect(key1 = true) {
        myViewModel.getItems()
    }

    LazyColumn(
        modifier = Modifier.padding(vertical = 20.dp, horizontal = 10.dp),
        verticalArrangement = Arrangement.spacedBy(12.dp)
    ) {
        items(myItems) { myItem ->
            Log.e("TestScreen", "Got $myItem") // <-- won't show updated list with "999"
        }
    }
}

我希望 collect {} 接收更新后的列表，但事实并非如此。 SharedFlow 或 StateFlow 并不重要，两者的行为相同。我可以让它工作的唯一方法是创建一个新列表并发出它。当我使用 SharedFlow 时，equals() 返回 true 或 false 并不重要。

    viewModelScope.launch {
        delay(3000)
        val newList = _items.toMutableList()
        newList[2] = DataItem("999", "For testing!!!!")
        items.emit(newList)
        Log.e("ViewModel", "Updated list")
    }

我不应该创建一个新列表。知道我做错了什么吗？

Answer 1

您每次都会发出相同的对象。 Flow 不关心相等性并发出它 - 您可以尝试手动收集它来检查它，但 Compose 会尝试尽可能地减少重组次数，因此它会检查是否状态值实际上已经改变了。

由于您发出可变列表，因此相同的对象存储在可变状态值中。它无法跟踪该对象的更改，当您再次发出它时，它会进行比较并发现数组对象是相同的，因此不需要重新组合。您可以在

解决方案是将可变列表转换为不可变列表：每次发出时它都会成为一个新对象。

items.emit(_items.toImmutableList())

另一个需要考虑的选项是使用 mutableStateListOf：

private val _items = mutableStateListOf<DataItem>()
val items: List<DataItem> = _items

suspend fun getItems() {
    _items.clear()

    viewModelScope.launch {
        repeat(5) {
            _items.add(DataItem(it.toString(), "Title $it"))
        }
    }

    viewModelScope.launch {
        delay(3000)
        val newItem = DataItem("999", "For testing!!!!")
        _items[2] = newItem
        Log.e("ViewModel", "Updated list")
    }
}

Answer 2

这是 state 和 jetpack 组合的预期行为。 Jetpack compose 仅​​在状态值发生变化时才重新组合。由于列表操作仅更改对象的内容，而不更改对象引用本身，因此组合不会被重新组合。

Answer 3

Room 数据库也有同样的问题。数据库中的每个新行也在状态中更新，但实体内部的更改不可见。按照 Phil Dukhov 的解决方案，我更改了 viewModel，以便数据库中的每次更改都会更新 UI：

class MemoViewModel(val noteDao: NoteDao):ViewModel() {
companion object {
    private const val TIMEOUT_MILLIS = 5_000L
}

val homeUiState: StateFlow<HomeUiState> =
    noteDao.getAllNotes().map { it: List<Note>
        HomeUiState(it.toMutableStateList())
    }
        .stateIn(
            scope = viewModelScope,
            started = SharingStarted.WhileSubscribed(TIMEOUT_MILLIS),
            initialValue = HomeUiState(mutableStateListOf())
        )
...
/**
 * Ui State for HomeScreen
 */
data class HomeUiState(
    val noteList: SnapshotStateList<Note>
)

这里的解决方案实际上是 Type: SnapshotStateList <>函数 mutableStateListOf() 的结果，观察列表中的每个变化。
该解决方案非常好，因为我的 DAO 仍然返回 List<> 并且 List<> 和 SnapshotStateList<> 上的语法是相同的。 Composable 和 StateCollector 也不需要更改。