Kotlin Flow 超时结果

Question

我正在尝试在 CoroutineWorker(WorkManager) 中使用 Flow，并且该流应该在存储库中侦听一个值 5 秒，如果您在该时间范围内获得该值，则返回 Result.success() 然后忽略/取消计时器，如果时间过去了，您返回 Result.failure()

现在我有类似的东西，我正在尝试在那里合并超时。

 repository.getListeningValue.onEach {
     //doStuff here with the result
 }.map{
     Result.success()
 }.first()

Answer 1

我会尝试这样的事情：

withTimeoutOrNull(5_000) {
    flow.first()
    Result.success()
} ?: Result.failure()

我自己没有尝试过，但我认为应该可以。