如何解决如何在 Kotlin Flow 中添加动态值
如果我们知道要在 Kotlin 流程中处理的列表值,那么我们可以遵循以下函数
flow {
(1..1000).forEach {
delay(1000) //Process Data
emit(it.toLong())
}
}.collect{
delay(2000)
print(it)
}
我们知道我们要打印从 1 到 1000 的值
就我而言,我在流程开始时没有输入值。我想在我有值 1 时开始流程,同时如果我有一个新值,那么我必须将它添加到队列中,直到值 1 被处理,然后开始处理新值,然后开始处理新值。>
基本上,我想在流程块之外增加价值,是否有任何解决方案可以实现这一点?
解决方法
您可以将 SharedFlow
与缓冲区一起使用。应该是这样的:
val myFlow = MutableSharedFlow<Long>()
你可以发出这样的值:
(1..1000).forEach {
delay(1000) //Process Data
println("Emitting $it")
myFlow.emit(it.toLong())
}
然后像这样收集它们:
myFlow
.buffer()
.collect {
delay(2000)
println("Received: $it")
}
如果您不使用 buffer
运算符,则每次发出值时,发出都会暂停,直到 collect
完成其工作。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。