Rxjava作爲事件總線

Question

我想在我的應用中使用Rxjava publishsubject實現事件處理。

事件總線將在多個活動，碎片和服務之間共享。

該服務執行我的後臺處理工作（每30秒運行一次）。

問題：

1. 我想，每一個具有某種標誌設置的事件被保存在數據庫中。我想爲此附上一個通用監聽器。我怎樣才能做到這一點？這種情況下應該運行？

2. 服務將讀取持續事件並在必要時處理它們。

Answer 1

最終我們實現了和RxBus。我們用本地db上的一個事件存儲來備份它。然後我們運行一個服務，查詢數據庫中的新事件，然後將其加載到總線上。

我們正在尋找一些默認會這樣做的產品。找不到一個。