rx-java

    0熱度

    1回答

    說,SomeOtherService在一個Veritcle在不同Verticle中使用UserService,通信發生在Event Bus上。在另一臺機器上的另一verticle /微服務 class SomeOtherService { final UserService userService = new UserService(); // Mutable state

    4熱度

    2回答

    我有一個關於RxJS combineLatest操作符的查詢。我已經修改了在 https://www.learnrxjs.io/operators/combination/combinelatest.html 給出的示例如下: //timerOne emits first value at 1s, then once every 4s const timerOne = Rx.Observable

    3熱度

    1回答

    我正在開發使用火力地堡,科特林和RxJava的應用程序。 基本上,我需要做的是註冊使用驗證從火力地堡的用戶,如果用戶選擇的照片,上傳照片,然後保存用戶從火力地堡數據庫。 到現在我有這個 RxFirebaseAuth.createUserWithEmailAndPassword(auth, email, password) .map { authResult -> us

    0熱度

    1回答

    我有一個類「內閣」有這樣的結構: class Cabinet { var title: String var floor: Int var cabinetNumber: Int } 而另一個階級「標籤」 class Tabs { var floor: Int var cabinetList: List<Cabinet> } 所以在RxJ

    0熱度

    2回答

    我正在嘗試管理請求調用。這是我的情況。我正在使用retrofit 2和RxJava。我在我的Fragment中的onResume方法中有一個API請求調用。當我在應用程序中切換選項卡或旋轉手機時,onResume方法會再次被調用,如果調用速度較慢,則發送兩個相同的請求並獲得2個相同的響應。你有什麼想法我可以如何防止這一點? 如果第一個API調用正在進行,或者以某種方式將2個響應合併爲一個(如果調用

    2熱度

    1回答

    我有一個observable,它會發出數據,我想先緩衝它三秒鐘,然後在初始緩衝區之後必須滑動一秒鐘。這更像是buffer(timespan,unit,skip)跳過的時間段。 樣品: ObservableData,TimeStamp : (5,1),(10,1.5),(30,2.8),(40,3.2),(60,3.8),(90,4.2) ExpectedList : {5,10,30},{10

    1熱度

    2回答

    因此,我正在開發一個由其他人開發的較老的項目,並且在項目中使用了RxAndroid。 我不得不在一些應用程序的請求中添加緩存處理,並且OkHttp緩存在我需要的時候效果不佳。所以我想出瞭解決方案來實現我自己的服務,它檢查互聯網連接,然後發出請求,或根據連接從緩存中讀取它。我沒有與RxAndroid經驗,但我讀了一下,我想出了這個: @Override public Observable<List

    0熱度

    2回答

    我正在使用Android室持久性庫,該庫返回MyModel的列表(Flowable<List<MyModel>>)的Flowable列表。 MyModel具有函數getMonth,它返回一個整數。 我想將MyModel分組到MyModelWrapper中,MyModelWrapper是MyModel和整數列表(MyModelWrapper(int month, List<MyModel>))的包裝

    0熱度

    1回答

    我有一個方法返回一個Single<List<Item>>,我想把這個列表中的每個項目傳遞給一個返回Completable的方法。我想等到每個項目成功完成並返回Completable結果。我最初的做法是分別使用flatMapIterable來處理每個項目,並使用toList組合結果,但我不能在Completable對象上調用toList。有沒有其他的方法可以用這種方式將許多Completable任務

    0熱度

    1回答

    如何配置log4j(v 2)以記錄具有WARN級別的MyException錯誤? 見代碼(rxjava)的例子,拋出異常MyException return map.get(id).toObservable() .filter(Objects::nonNull) .switchIfEmpty(Observable.error(new MyException("Hap