在Kotlin callbackFlow构建器中捕获异常

import kotlinx.coroutines.*
import kotlinx.coroutines.channels.awaitClose
import kotlinx.coroutines.flow.callbackFlow

fun fetchDataFromRemote(callback: (String?, Exception?) -> Unit) {
    // 模拟异步操作
    GlobalScope.launch {
        delay(1000) // 假设这里发生了异常
        callback(null, Exception("网络连接失败"))
    }
}

fun main() = runBlocking {
    val flow = callbackFlow<String> {
        val callback: (String?, Exception?) -> Unit = { data, exception ->
            if (exception != null) {
                // 异常处理
                try {
                    throw exception
                } catch (e: Exception) {
                    // 在这里处理异常
                    offer("发生异常：${e.message}")
                }
            } else {
                // 正常情况
                offer(data)
            }
        }

        fetchDataFromRemote(callback)

        awaitClose()
    }

    flow.collect { data ->
        println(data)
    }
}