主页 / coding / 问题 / 76979163
Accepted
braml1
Asked: 2023-08-26 00:55:25 +0800 CST

Kotlin 收集 SharedFlow 未收集

  • 772

假设我有一个发出流的类，以及另一个类中收集流的函数：

这有效

class DebugMessage {
   val sharedFlow = MutableSharedFlow<String>()

   fun makeFlow() {
       GlobalScope.launch(Dispatchers.Default) {
           for (i in 0 until 10) {
               sharedFlow.emit(Random.nextInt(1,100).toString())
               delay(200)
           }
       }
   }

   fun getFlow(): Flow<String> {
       makeFlow()
       return sharedFlow
   }
}

和

private fun collectDebugMsg() {
   GlobalScope.launch(Dispatchers.Default) {
       val getFlow = DebugMessage().getFlow()
       getFlow.collect { Timber.d("VALUE IS $it") }
   }
}

这按预期工作，但有点无用。我需要拆分makeFlow和getFlow功能。我会先调用该makeFlow函数，然后再getFlow调用该函数，例如：

这不起作用

class DebugMessage {
   val sharedFlow = MutableSharedFlow<String>()

   fun makeFlow() {
       GlobalScope.launch(Dispatchers.Default) {
           for (i in 0 until 10) {
               sharedFlow.emit(Random.nextInt(1,100).toString())
               delay(200)
           }
       }
   }

   fun getFlow(): Flow<String> {
       //makeFlow() // Call 'makeFlow' from outside the DebugMessage Class
       return sharedFlow
   }
}

和

private fun collectDebugMsg() {
   GlobalScope.launch(Dispatchers.Default) {
       DebugMessage().makeFlow() // Call 'makeFlow' from outside the DebugMessage Class
       val getFlow = DebugMessage().getFlow()
       getFlow.collect { Timber.d("VALUE IS $it") }
   }
}

该流不再收集任何东西。有人知道这是为什么吗？

kotlin

1 个回答

  1. Best Answer

    每次调用都会DebugMessage()创建该类的一个新的、不同的实例DebugMessage。DebugMessage().makeFlow()创建一个实例并“激活”它，然后DebugMessage().getFlow()创建另一个实例并在仍未激活时收集其流量。要解决此问题，您必须从激活的同一实例收集：

    val debugMessage = DebugMessage()
debugMessage.makeFlow()
val getFlow = debugMessage.getFlow()
    • 2

相关问题