event-bus

    2熱度

    2回答

    我已經實現了簡單的RxEventBus,即使沒有訂閱者,它也可以開始發送事件。我想緩存最後發出的事件,這樣如果第一個/下一個訂閱者訂閱,它只接收一個(最後一個)項目。 我創建測試類,它描述了我的問題: public class RxBus { ApplicationsRxEventBus applicationsRxEventBus; public RxBus() { appli

    8熱度

    1回答

    我期待它是如何通過Spring引導和電抗器有多個應用程序(它自己的Spring引導容器上運行的每一個),其使用一個獨立運行的一個共享/共享EventBus - 單獨的容器。 它是一個具有多個應用程序的微服務環境,每個應用程序都是專用的,並且應該在事件鏈中調用。 可能嗎? 這是代表場景圖: 預先感謝您。

    0熱度

    1回答

    在我的應用程序中,我有一個事件總線分配來自外部的消息。我想分發包含一些Controldata的消息。我想用對象的類型是這樣的 class NewMessage<MESSAGE_TYPE> { MESSAGE_TYPE message; Controldata controldata; } 既然不能認購通用 NewMessage<MyMessage> 我創建了一個解決方

    0熱度

    1回答

    我正在使用EventBus greenrobot編寫Android應用程序。例如,我有一個Activity,它是我們情況下的發佈者,我們有一些自定義類 - 只是簡單的類,它是訂閱者。我們假設我從活動中發佈活動。據我瞭解,我們沒有任何自定義類的實例,因爲現在它與活動分離。那麼我怎樣才能讓這個類的實例總是有的。 或者可能是我錯誤地使用了Eventbus。

    3熱度

    2回答

    我正在使用與EventBus(Otto)相結合的Model-View-Presenter設計模式。我實現此模式的全部原因是僅將事件與演示者分開,並讓演示者更新視圖。 這是一些我有的代碼的例子,我將以Events爲例。 (請注意,Events與EventBusEvent不同,這意味着Events中的Event是類似於「爸爸的生日」的事件,但EventBus中的Event是總線事件)。 片段 publ

    0熱度

    2回答

    我想使用signalR從我的服務器向客戶端代理廣播事件。 服務器使用多租戶體系結構,我想通過signalR組來分隔signalR-Hub中的每個租戶。 此外,我想通過signalR廣播我的「框架事件」。客戶應該爲自己需要的事件註冊。 可以此問題,通過「signalR-主題」或覆蓋必須在客戶端註冊僅他想要的事件,如: myHub.On<string>("addMessage", param => {

    2熱度

    1回答

    我們試圖使用事件總線在垂直版本之間建立通信。我們嘗試了最簡單的乒乓通信示例 - public class Sender extends AbstractVerticle { public static void main(String[] args) { Vertx.clusteredVertx(new VertxOptions(),res->{ res.res

    3熱度

    2回答

    Guava EventBus文檔說 「處理程序通常不應拋出,如果這樣做,EventBus將捕獲並記錄異常,這很少是錯誤的正確解決方案處理,不應該依賴,它只是爲了幫助發現問題。「 如果您知道可能會發生某些異常,可以使用EventBus註冊SubscriberExceptionHandler並使用它來處理這些異常。 但是,如果發生未處理的異常會發生什麼?通常情況下,我想要一個未處理的異常來「調出」調用

    0熱度

    1回答

    在我的應用程序中,我有兩個按鈕使用事件總線(Otto)發送帶ID的事件。根據這個ID,應用程序會進入不同片段之間導航的不同級別。當用戶在同一毫秒內點擊兩個不同的按鈕時,是否有可能避免事件總線在相同的毫秒內發送相同的事件(具有不同的ID)?我附上了一張圖片以顯示我的Logcat。 謝謝! EDIT 1: 使用syncronized兩者的onClick方法訂閱方法,我繼續接收在同一毫秒的事件。現在,關

    1熱度

    3回答

    我正在寫一個應用程序,它接收來自JNI的Java類中靜態方法的調用。 例如 public class Receiver { // method called from C++ in some thread private static void receive(int value) { EventBus.instance().post(new ReceiverEve