如何解决挂起直到 StateFlow 达到所需状态之一并返回结果
考虑一个密封的类状态。
sealed class State {
object UnkNown : State()
object Loading : State()
object Success : State()
data class Failure(val exception: Exception)
}
val state:State = MutableStateFlow(State.UnkNown)
现在,我还想有一个简单的挂起方法,它会等待状态达到 Success 或 Failure,这样只需要一次结果的消费者就不需要知道状态流。
如何实现这一目标?
解决方法
虽然您已经想出了一个可行的解决方案,但为了简单起见,您可能希望使用内置的 Flow.first { ... }
运算符。
suspend fun waitForResult(): State {
val resultStates = setOf(State.Success::class,State.Failure::class)
return state.first { it::class in resultStates }
}
,
我想出了以下看起来工作正常的扩展函数。
suspend fun waitForResult(): State {
val resultStates = setOf(State.Success::class,State.Failure::class)
return state.waitForStates(resultStates)
}
suspend fun <T : Any> StateFlow<T>.waitForStates(states: Set<KClass<out T>>): T = coroutineScope {
var currentValue = value
// not needed for correctness,just an optimisation
if (currentValue::class in states) {
return currentValue
}
coroutineScope {
collect {
if (it::class in states) {
currentValue = it
cancel()
}
}
}
return currentValue
}
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。