如何通过合并将Kotlin Flow事件发送到现有的Flow流中

Question

我有两个流。

CCD_ 1每秒发出一个整数流。

单击按钮时，flow2()会发出一个整数。

两个流都与combinedFlows()组合，并且组合的结果在textView中被收集和输出。

问题：当我点击button时，文本视图没有更新流2点击次数。由于某种原因，combine{ }操作员在单击时未收集flow2()。如何将flow2()发送到现有流中并在文本视图中收集结果？

class MainActivity : AppCompatActivity() {
override fun onCreate(savedInstanceState: Bundle?) {
super.onCreate(savedInstanceState)
val binding = ActivityMainBinding.inflate(layoutInflater)
setContentView(binding.root)
CoroutineScope(Dispatchers.Main).launch {
combineFlows().collect {
binding.textView.text = "flow1: ${it.first} and flow2 click count: ${it.second}"
}
}
binding.button.setOnClickListener {
CoroutineScope(Dispatchers.Main).launch {
flow2().collect()
}
}
}
fun flow1() = (1..1000).asFlow().onEach { delay(1000) }
fun flow2() = flow {
var i = 0
i++
emit("$i")
}
fun combineFlows() = combine(flow1(), flow2()) { a, b -> Pair(a, b) }
}

<androidx.constraintlayout.widget.ConstraintLayout xmlns:android="http://schemas.android.com/apk/res/android"
xmlns:app="http://schemas.android.com/apk/res-auto"
xmlns:tools="http://schemas.android.com/tools"
android:layout_width="match_parent"
android:layout_height="match_parent"
tools:context=".MainActivity">
<TextView
android:id="@+id/textView"
android:layout_width="wrap_content"
android:layout_height="wrap_content"
android:text="Hello World!"
app:layout_constraintBottom_toBottomOf="parent"
app:layout_constraintEnd_toEndOf="parent"
app:layout_constraintStart_toStartOf="parent"
app:layout_constraintTop_toTopOf="parent" />
<Button
android:id="@+id/button"
android:layout_width="170dp"
android:layout_height="35dp"
android:textSize="11sp"
android:text="Emit Flow"
app:layout_constraintBottom_toBottomOf="parent"
app:layout_constraintEnd_toEndOf="parent"
app:layout_constraintStart_toStartOf="parent"
app:layout_constraintTop_toBottomOf="@+id/textView" />
</androidx.constraintlayout.widget.ConstraintLayout>

Answer 1

flow {}构建器是一个冷流，这意味着它在调用终端运算符时执行。当调用flow1()0构建器时，它会创建一个新的Flow实例。因此，在combine(flow1(), flow2()) { a, b -> Pair(a, b) }和flow2().collect()中调用flow2()两次将创建Flow的两个不同实例。

按钮点击应该被视为一个热流——所有收集器都不会获得所有事件，它们只接收最后一个事件(或者只接收最后几个事件，具体取决于热流的配置方式(。

SharedFlow和StateFlow是热流，可用于以下目的：

private val counter = MutableStateFlow(0)
binding.button.setOnClickListener {
counter.update { count -> count + 1 }
}
fun combineFlows() = combine(flow1(), counter) { a, b -> Pair(a, b) }