通过 Kotlin 中的另一个挂起函数发出流

Question

我怎样才能让下面的流量收集器收到“你好”？收集器正在调用myFunction1()，后者又调用myFunction2()。两者都是暂停功能。

目前，当我点击运行时没有任何反应，也没有收到任何流量。我在这里错过了什么吗？

CoroutineScope(IO).launch {
    val flowCollector = repo.myFunction1()
        .onEach { string ->
            Log.d("flow received: ", string)
        }
        .launchIn(GlobalScope)
}

class Repo {

    suspend fun myFunction1(): Flow<String> = flow {
        /*some code*/
        myFunction2()
    }

    suspend fun myFunction2(): Flow<String> = flow {
        /*some code*/
        emit("hello")
    }
}

Answer 1

您可以针对您的情况尝试使用emitAll 函数：

fun myFunction1(): Flow<String> = flow {
    /*some code*/
    emitAll(myFunction2())
}

fun myFunction2(): Flow<String> = flow {
    /*some code*/
    emit("hello")
}

emitAll 函数从 Flow 收集所有值，由 myFunction2() 函数创建并将它们发送到收集器。

并且没有理由在每个函数之前设置一个suspend修饰符，flow构建器不是suspend。

Answer 2

除非你有一个非常具体的原因，否则从你的回购中返回 Flow 的函数不应该被暂停（因为 flow{} 构建器没有暂停）。由于挂起操作正在收集（等待值从中出来）。

从您提供的代码中，您正在寻找 flatMapLatest 函数。 Docs here

class Repo {

  fun function1() = 
    flow {
      val value = doSomething()
      emit(value)
    }
    .flatMapLatest { emittedValue -> function2() }
  fun function2() = flow {...}
}