Rxjava作为事件总线

Question

我想在我的应用中使用Rxjava publishsubject实现事件处理。

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

该服务执行我的后台处理工作（每30秒运行一次）。

问题：

1. 我想，每一个具有某种标志设置的事件被保存在数据库中。我想为此附上一个通用监听器。我怎样才能做到这一点？这种情况下应该运行？

2. 服务将读取持续事件并在必要时处理它们。

Answer 1

最终我们实现了和RxBus。我们用本地db上的一个事件存储来备份它。然后我们运行一个服务，查询数据库中的新事件，然后将其加载到总线上。

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