0

如果我们知道要在 Kotlin 流程中处理的列表值,那么我们可以遵循以下函数

  flow {
          (1..1000).forEach {
            delay(1000) //Process Data
            emit(it.toLong())
          }
       }.collect{
            delay(2000)
            print(it)
        }

我们知道我们将打印从 1 到 1000 的值

就我而言,我在流程开始时没有输入值。我想在我有值 1 时启动流程并同时开始数据处理,如果我有一个新值,那么我必须将它添加到队列中,等待值 1 得到处理,然后开始处理新值。

基本上,我想在流程块之外添加价值,是否有任何解决方案可以实现这一目标?

4

1 回答 1

2

您可以将 a SharedFlowfor 与缓冲区一起使用。它会是这样的:

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完成它的工作。

于 2021-07-06T10:49:12.740 回答