发送数据时Channel自动关闭的原因及保持通道开启的方法

你遇到的通道提前关闭问题，核心原因是**channelFlow构建器的特性**：当传入的构建lambda执行完毕且没有挂起操作时，通道会自动关闭。

看你的handleInput函数，lambda里仅完成了给myEmitter设置Listener的操作，没有任何挂起逻辑，所以lambda执行结束的瞬间，通道就被自动关闭了。后续调用sendData时，通道已经处于关闭状态，trySend自然会返回通道已关闭的结果。

另外还有执行顺序的问题：main函数里的collect是挂起函数，会阻塞到通道关闭才会继续执行后续的sendData和close。但通道在handleInput返回后立刻关闭，collect直接结束，之后才执行sendData，这时候通道早就处于关闭状态了。

要让通道保持开启，你需要在channelFlow中使用awaitClose函数——它会挂起构建lambda，直到通道被主动关闭或collect协程被取消，同时还能在回调中做资源清理。

修改后的代码如下：

interface Listener {
    fun onGetData(data: Int)
    fun onClose()
}

class MyEmitter {
    var listener: Listener? = null
    fun sendData(data: Int) = listener?.onGetData(data)
    fun close() = listener?.onClose()
}

fun handleInput(myEmitter: MyEmitter) = channelFlow {
    val listener = object : Listener {
        override fun onGetData(data: Int) { trySend(data) }
        override fun onClose() { close() }
    }
    myEmitter.listener = listener
    
    // 挂起直到通道关闭，同时清理listener避免内存泄漏
    awaitClose {
        myEmitter.listener = null
    }
}

fun main(): Unit = runBlocking {
    val myEmitter = MyEmitter()
    
    // 启动独立协程执行collect，避免阻塞后续发送逻辑
    launch {
        handleInput(myEmitter).collect {
            println(it)
        }
    }

    myEmitter.sendData(1)
    myEmitter.sendData(2)
    myEmitter.close()
}

这里做了两个关键调整：

• 添加awaitClose：让channelFlow的构建lambda保持挂起状态，通道不会自动关闭，直到我们通过myEmitter.close()触发通道的close()方法，或者collect协程被取消。同时在回调中清空myEmitter的listener，避免内存泄漏。
• 用launch启动collect协程：避免collect阻塞后续的sendData和close调用，保证数据能正常发送到通道中。

修改后，通道会保持开启状态，直到myEmitter.close()调用触发Listener.onClose()，进而关闭通道，此时collect才会结束执行。

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