从常规java函数向kotlin的流发送数据

Question

我有一个无法更改的外部接口：

interface ExternalApi {
    fun onDataReceived(data: String)
}

我需要开始使用数据，并将其发送到< code>flow。数据顺序是必须的。我想要一个冷< code >流，但是我找不到一个具有< code>emit函数的冷< code >流版本，所以我使用热< code >流重放设置为最大值作为解决方法。这是我的第一次尝试:

class FlowProblem {
    val flow: MutableSharedFlow<String> = MutableSharedFlow(replay = Int.MAX_VALUE)

    fun startConsuming() {
        object : ExternalApi {
            override fun onDataReceived(data: String) {
                flow.emit(data)
            }
        }
    }
}

不幸的是，它不起作用，因为 emit 函数是一个挂起的函数。但是，这是一个外部接口，我无法添加挂起修饰符。我也试图做这样的事情：

override fun onDataReceived(data: String) {
    val coroutineScope = CoroutineScope(Job())
    coroutineScope.launch {
        flow.emit(data)
    }
}

但对我来说，创建新的协程只是为了让数据流动是有点愚蠢的。我还想知道数据顺序。

我该怎么办？也许流量/通道不适合这里，我应该选择另一个？

Answer 1

感谢IR42，callbackFlow正是我所需要的。