rxjava作为活动巴士

Question

我正在尝试使用rxjava PublishSubject在我的应用中实现事件处理。

活动总线将在多个活动，碎片和服务之间共享。

服务完成我的背景处理工作（每30秒运行一次）。

问题：

1. 我希望将所有具有一些标志的事件保存在DB中。我想为此附上一个通用听众。我该如何实现？在哪个上下文中应该运行？

2. 服务将读取持续的事件并在此认为，如果有必要。

Answer 1

最终我们实现了RXBU。我们在本地DB上的活动店备份了它。然后，我们运行了一项服务，该服务将数据库查询新事件，然后将其加载到总线上。

我们正在寻找一些默认情况下这样做的产品。找不到一个。