首页 > 解决方案 > ClosedReceiveChannelException 和数据绑定问题

问题描述

我正在编写一段代码,它使用 Kotlin 的协程 pipilens 和 Androids 数据绑定。

在工作时,我发现当我的 couroutine 由于“ClosedReceiveChannelException”而崩溃时,绑定的视图模型(通过数据绑定)不会更新“数据绑定组件”。

fun onProcessStart(cachedImageId: String) = viewModelScope.launch {
    text = "Started for image: $cachedImageId"

    try {
        val extractedTextPipe = extractText(cachedImageId)
        val processedTextPipe = processText(extractedTextPipe)
        val processedText = processedTextPipe.receive()
        text = "Finished for image: $cachedImageId"
    } catch (t: Throwable) {
        Log.d("TEST", t.message+ " "+t)
        text = "Failed for image: $cachedImageId with code: ${t.message}"
    }
}

尽管触发了捕获并且Log.d日志中存在text新消息,但它永远不会更新。

如果以下内容也不起作用,那就不足为奇了:

 fun onProcessStart(cachedImageId: String) = viewModelScope.launch {
        text = "Started for image: $cachedImageId"

        try {
            throw IllegalStateException()
            text = "Finished for image: $cachedImageId"
        } catch (t: Throwable) {
            Log.d("TEST", t.message+ " "+t)
            text = "Failed for image: $cachedImageId with code: ${t.message}"
        }
    }

上面的代码有效 - 中的文本catch已更新。

我的问题是 - 为什么一旦val processedText = processedTextPipe.receive()抛出值ClosedReceiveChannelExceptiontext停止更新。

--编辑这个问题也可以通过以下方式观察到:

  text = "Started for image: $cachedImageId"

    try {
        delay(10000)
        throw IllegalStateException()
    } catch (t: Throwable) {
        Log.d("TEST", t.message + " " + t + " " + Thread.currentThread().id)
        text = "Failed for image: $cachedImageId with code: ${t.message}"
    }

标签: androidkotlinandroid-databindingkotlin-coroutines

解决方案


好吧 - 经过一夜好眠后,我发现我忘记LiveDatatext野外使用了。


推荐阅读