Kotlin take(int).toList() 省略第一个元素

Question

我有一个每 2 秒发出一次项目的测试 LiveData。我将它转换为流并在其上调用 take(3).toList()。

val list = newLiveData
            .asFlow()
            .onEach {
                println("Item ${it.status}")
            }
           .take(3)
           .toList()

println(list.joinToString {  "${it.status} " })

该 liveData 的实现使其首先发出 LOADING，然后继续发出 SUCCESS，所以我期待在列表中看到：

LOADING, SUCCESS, SUCCESS

但出于某种原因 returns 只是

Item LOADING
Item SUCCESS
Item SUCCESS
SUCCESS , SUCCESS , SUCCESS

奇怪的是，它在 onEach 中打印了正确的值，如果我将 "take(3)" 替换为 "first()"，我确实获得了正确的加载状态。

有人遇到过这种行为吗？它对我来说看起来不太合适，所以如果不是已知案例，我会打开一个错误报告。

Answer 1

事实证明这是因为我的 LiveData 不断修改一个对象并发送它，而不是每次都创建一个新实例。

我有一个类似这样的 LiveData：

class EmittingLiveData : LiveData<StateData<Int>>() {

    init {
        value = StateData()
    }

    override fun observe(owner: LifecycleOwner, observer: Observer<in StateData<Int>>) {
        startEmitting()
        super.observe(owner, observer)
    }

    override fun observeForever(observer: Observer<in StateData<Int>>) {
        startEmitting()
        super.observeForever(observer)
    }

    private fun startEmitting() {
        GlobalScope.launch(Dispatchers.Unconfined) {
            value = value?.loading()

            async {
                while (this.isActive) {
                    delay(1000)
                    postValue(value?.success(0))
                }
            }.start()
        }
    }

}

并且必须将发布值更改为

postValue(StateData<Int>().success(0))

菜鸟 - 对象引用 - 问题，但我没想到会这样。所以也许其他人也会发现这有帮助:)

感谢帮助我的人 qwwdfsad github issue

Kotlin take(int).toList() 省略第一个元素

Kotlin take(int).toList() omits first element

android

kotlin

android-livedata