android – 用RxJava替换EventBus – N个用户总是在听

我在 Android应用程序中用RxJava替换EventBus模式.我有事件提醒任何有兴趣的方面我的缓存单身人数据的更新.任何时间调用Web服务,数据将被更新,订阅者将通过已发布的事件进行提醒.

我有一些接近这个设置在RxJava与AsyncSubject.观察者从主题获得单个事件,但是它们会获得一个onComplete事件并取消订阅.这在UI首次加载时起作用,但是当数据需要刷新时,没有订阅者被通知.如何告知这些订阅者会继续收听来自主题的下一个事件？

我需要一个可以报告最近的项目的主题. PublishSubject仅在订阅之后才会发出项目,所以不太符合我的需求.我的用户在不同的时间(可能在第一个数据事件之后)开始观察,所以我需要主体发出观察到的最后一个项目,然后保持流为后续项目打开.看来AsyncSubject和PublishSubject的组合是我需要的.有没有办法用内置的课程来完成这个,还是需要创建自己的课程？

WebServiceObservable OR CacheObservable
                  ^
                  |
             AsyncSubject
                  ^
                  |
                /   \
              /       \
            /           \
      UiObserver1   UiObserver2

解决方法

稍微迟一点的答案,但是比BehaviorSubject稍微更好一些的选择可能是来自 RxRelay lib的BehaviorRelay,并且当需要不同的行为但希望在所有可以使用的模块之间共享单点交互时,可以获得更多的全球解决方案 RxHub