rx-java

2熱度

1回答

我將使用Java編寫的Android應用程序移植到Groovy。我正在嘗試使用Groovy閉包，但它不起作用。編譯並運行時沒有錯誤，但沒有任何反應。這是不起作用的版本。 Observable.create({ Subscriber<Bin> subscriber -> new Thread(new Runnable() { @Override

1熱度

1回答

rxjava android測試一個典型的REST查詢

我想在REST服務器和我的Android應用程序之間執行集成測試。總之，我的應用程序執行get查詢來獲取json元素數組（'場景'）。我的測試通過了，但幾乎沒有優雅和高效，因爲我引入了10秒的延遲。在我最後的斷言之前，我更喜歡像'observationThread.join（）'這樣的東西，但是到目前爲止我還沒有找到方法。有什麼想法？這裏是我的代碼： public void test_s

6熱度

1回答

爪哇枚舉與沒有實例

在RXJava [1]有[2]定義爲 public enum JavaFxObservable { ; // no instances public static void staticMethod() { // ... } } 什麼目的使用枚舉沒有實例這種技術枚舉？爲什麼不使用標準課程？ [1] https://github.com/React

4熱度

3回答

如何在調用rx.Observable.sample（）時接收最後的序列發射？

我正在從遠程URL讀取文件並使用RxJava報告下載進度。文件編寫器Observable發出一系列DownloadProgress對象。由於很多項目正在發射，我使用Observable.sample（）來管理背壓。這非常有效 - UI更新以恆定的速率進行，並且沒有背壓問題，但最後的進度更新幾乎總是被忽略。我想收到Observable序列中的最後一項，以便我可以用最終進度更新UI。確保始終發出Ob

27熱度

4回答

Observable在onNext（）中不傳遞任何東西（）

我需要一個Observable，例如提供一個系統時鐘，它不需要在onNext（）中傳遞任何東西。我找不到可以讓我這樣做的簽名。當然，我可以使用任何對象，然後傳遞null，但這沒有多大意義。所以我的問題是如果有更好的方法來做到這一點。 Observable.create(new Observable.OnSubscribe<Anyobject>() { // use any object in t

2熱度

1回答

如何訂閱點擊事件，以便例外不退訂？

我使用RxJava for Android (RxAndroid)和我訂閱點擊視圖的事件，並做一些對他們如下： subscription = ViewObservable.clicks(view, false) .map(...) .subscribe(subscriberA); 的問題是，每當有一個例外，subscriberA自動退訂，通往下點擊沒有觸發任何東西。如何處

1熱度

1回答

如何處理Observable發出的項目以訪問另一個值？

我需要執行一個異步call_1，趕上它的Observable reply_1，然後再做一個異步call_2，並在處理它的reply_2時我還需要訪問reply_1。我已經試過類似： public rx.Observable<Game> findGame(long templateId, GameModelType game_model, GameStateType state) { rx.O

0熱度

1回答

發射2個可觀測量，處理的結果，然後發射另一個

我有以下要執行的任務：我需要發射2個可觀測量（OBS1 & OBS2）處理其結果，然後調用另一個可觀察到的（obs3）和處理其結果，並且如果可能的話，在處理obs3的結果時可以訪問obs1和obs2的結果。這是我的草案代碼，它沒有這樣做，我該如何改變它。 public void executeFind(String session_id, long template_id, GameModel

2熱度

1回答

爲什麼我的計時器Observable從不叫？

在Android上，我寫了一個Observable，它應該在2000毫秒後被調用一次，但從未被調用過。 Observable.timer(2000, TimeUnit.MILLISECONDS) // wait 2000 msec .subscribeOn(Schedulers.newThread()).observeOn(AndroidSchedulers.mainThread()

3熱度

1回答

如何從可觀察使用的是Android庫時取消

在Why is my timer Observable never called? @Miguel兒說：記住「記住，如果你使用的觀測量從一個片段或一個活動中，你應該始終確保你取消訂閱您的Observables以消除內存泄漏的可能性。「只要我在活動，片段或視圖中使用Observable，我就很清楚它是如何工作的。但是如果我在沒有語境的情況下使用它呢？我的情況：我有一個包含對象模型的外部庫。每個