是否有可能以某种方式保持 Observable/Flowable 的排放以及根据需要触发排放的某种方式？

Question

我是 RxJava2 的新手，我使用过其他方法 defer、concat 和 create。我正在尝试寻找一种方法来实现我上面描述的内容。

具体需要是这样的，我有一个显示和隐藏的片段。这个片段有subscribers 到EventBus 事件。这些事件是由我一直在后台运行的服务触发的。

我不想在片段隐藏时丢失发射。相反，我想以某种方式 cache 发射，在隐藏时发射，然后在显示片段时发射。

是否有使用 RxJava2 API 的内置解决方案？

Answer 1

具体需要是这样的，我有一个显示和隐藏的片段。 这个片段有 EventBus 事件的订阅者。事件是 由我一直在后台运行的服务触发。

如果我已经在使用 RxJava，我不会使用 EventBus

我不想在隐藏片段时丢失发射。 相反，我想以某种方式缓存排放，同时发出 被隐藏，然后在显示片段时发出它们。

我会为此使用ReplaySubject。来自文档

ReplaySubject 向任何观察者发射所有发射的项目 由源 Observable(s)，无论观察者何时 订阅。