流程 - 暂停/恢复流程

Question

在 RxJava 中，有一个valve运算符允许暂停（和缓冲）流并再次恢复流（并且在恢复后立即发出缓冲的值）。它是 rx java 扩展的一部分（https://github.com/akarnokd/RxJavaExtensions/blob/3.x/src/main/java/hu/akarnokd/rxjava3/operators/FlowableValve.java）。

kotlin 流程有类似的东西吗？

我的用例是我想观察活动内的流程并且永远不会丢失事件（就像我会用LiveDataeg 做的那样，如果活动暂停，它将停止观察数据）。因此，当活动暂停时，我希望流程缓冲观察到的值，直到活动恢复为止，并在活动恢复后立即将它们全部发出。

因此，当活动被创建时（直到它被销毁），我想观察流程，但我只想在活动处于活动状态时发出值，并在活动不活动（但仍然创建）时缓冲值，直到它再次活动。

有什么办法可以解决这个问题或者有人写过什么东西来解决这个问题吗？

Answer 1