如何使用Kotlin Flow从异步回调中发出数据？

import kotlinx.coroutines.*
import kotlinx.coroutines.flow.*

fun main() {
    // 创建一个Flow对象
    val flow = callbackFlow<String> { continuation ->
        val callback = object : Callback {
            override fun onDataReceived(data: String) {
                // 发射数据
                continuation.resume(data)
            }
            
            override fun onError(error: Throwable) {
                // 发射错误
                continuation.resumeWithException(error)
            }
        }
        
        // 注册回调
        registerCallback(callback)
        
        // 当Flow被取消时，取消回调
        continuation.invokeOnCancellation {
            unregisterCallback(callback)
        }
    }
    
    // 收集并处理数据
    GlobalScope.launch {
        flow.collect { data ->
            // 处理收集到的数据
            println(data)
        }
    }
    
    // 模拟回调数据
    sendCallbackData("Hello")
    sendCallbackData("World")
    
    // 等待一段时间
    Thread.sleep(1000)
    
    // 关闭Flow
    flow.cancel()
}

// 模拟回调接口
interface Callback {
    fun onDataReceived(data: String)
    fun onError(error: Throwable)
}

// 模拟注册回调
fun registerCallback(callback: Callback) {
    // 注册回调逻辑
}

// 模拟取消注册回调
fun unregisterCallback(callback: Callback) {
    // 取消注册回调逻辑
}

// 模拟发送回调数据
fun sendCallbackData(data: String) {
    // 发送回调数据逻辑
    // ...
}