Rxjava 作为事件总线
Rxjava as event bus
我正在尝试使用 Rxjava publishsubject 在我的应用程序中实现事件处理。
事件总线将在多个活动、片段和服务之间共享。
该服务执行我的后台处理工作（每 30 秒 运行 秒）。
问题：
我希望每个设置了标志的事件都保存在数据库中。我想为此附加一个通用侦听器。我怎样才能做到这一点？这个 运行?
服务将读取持久化事件并在其认为必要时处理它们。
最终我们实现了RxBus。我们使用本地数据库上的事件存储对其进行备份。然后我们 运行 一个服务，它查询数据库以获取新事件，然后将这些事件加载到总线上。
我们正在寻找一些默认情况下执行此操作的产品。找不到一个。
我正在尝试使用 Rxjava publishsubject 在我的应用程序中实现事件处理。
事件总线将在多个活动、片段和服务之间共享。
该服务执行我的后台处理工作（每 30 秒 运行 秒）。
问题：
我希望每个设置了标志的事件都保存在数据库中。我想为此附加一个通用侦听器。我怎样才能做到这一点？这个 运行?
在什么情况下应该
服务将读取持久化事件并在其认为必要时处理它们。
最终我们实现了RxBus。我们使用本地数据库上的事件存储对其进行备份。然后我们 运行 一个服务，它查询数据库以获取新事件，然后将这些事件加载到总线上。
我们正在寻找一些默认情况下执行此操作的产品。找不到一个。