android - 如何在 Kotlin Flow 中添加动态值
问题描述
如果我们知道要在 Kotlin 流程中处理的列表值,那么我们可以遵循以下函数
flow {
(1..1000).forEach {
delay(1000) //Process Data
emit(it.toLong())
}
}.collect{
delay(2000)
print(it)
}
我们知道我们将打印从 1 到 1000 的值
就我而言,我在流程开始时没有输入值。我想在我有值 1 时启动流程并同时开始数据处理,如果我有一个新值,那么我必须将它添加到队列中,等待值 1 得到处理,然后开始处理新值。
基本上,我想在流程块之外添加价值,是否有任何解决方案可以实现这一目标?
解决方案
您可以将 a SharedFlow
for 与缓冲区一起使用。它会是这样的:
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
完成它的工作。
推荐阅读
- algorithm - 如何有效地移动数字中的小数点直到达到某个阈值
- javascript - 使用 createMuiTheme 更改 Material UI 的 H1
- android - 创建同步的网络和移动应用程序。使用哪些技术
- python - r 中的简单 download.file() 不适用于 requests.get
- node.js - 使用没有框架或 npm 模块的纯 node.js 重定向响应
- python - 从 Python 列表中删除公因子
- github - 使用分页获取所有公共 github 存储库
- javascript - 在保存更改时添加到列表中后,相同的数据显示两次 - 反应
- ios - 为 tableViewCell 上的披露指示器着色?
- scala - 无法理解 Scala 操作在 Apache spark 中的作用如何