android - 当 block 在 Runnable 体内时发出 Flow 值

Question

所以我有这个函数，我可以用流发出值，但我需要定期发送值，所以我使用了:

fun hereIsAFunction(): Flow<Type> = flow {
    Handler.postDelayed({
        //This is in Runnable and I can't emit values
        emit(value) //Error 'Suspension function can only be called within Coroutine body
    }, 1000)

    usingOtherFunction()
}

我不想阻止函数“usingOtherFunction()”，这就是我使用可运行对象的原因

问题:有什么方法可以通过周期性事件通过 Flow 发出值吗？如果是，我应该调查什么？

Answer 1

根据您想要并行执行某些操作的评论，您可以在一个范围内启动 2 个协程。它们将彼此独立运行:

fun hereIsAFunction(): Flow<Type> = flow {
    coroutineScope {
        launch {
            (0..100).forEach {
                delay(1000)
                emit(...)
            }
        }
        launch {
            usingOtherFunction()
        }
    }
}