rx-java

7熱度

2回答

我試圖用robolectric爲一段代碼編寫單元測試。問題是，我需要假HTTP調用，但似乎robolectric的假層將其與Apache的HttpClient的按照這個答案只適用： Link to answer 在改造你不能改變URL所以MockWebServer似乎不是一種選擇。看來，mockito可以捕獲翻新回調，但我使用rxJava，所以我不知道它是否可以幫助。有沒有人對Robolect

1熱度

2回答

如何避免重複常見的可觀察配置？

我在Android中使用改裝寫的API客戶端和這種代碼被重複了很多： myObservableFromRetrofit .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .doOnError(... print stack trace ...) 我想知道如果有一種技術來

40熱度

1回答

如果對RxJava主題進行onComplete調用，是否需要再次手動取消訂閱？

我在我的Fragment中使用RxJava ReplaySubject。我試圖以一種方式使用ReplaySubject，我希望主體執行一個進程直到完成（可能超出片段的生命期）。完成該過程後，我想釋放資源 - 據我瞭解 - 通過在註冊觀察者（在我的情況下，是主題本身）時取消訂閱來完成。在這種github issue thread @benjchristensen說：如果它是可觀察到的，那麼它

7熱度

1回答

RxJava onErrorResumeNext（）

我有兩個observables（簡稱爲A和B）和一個訂戶。因此，訂閱者訂閱A，如果A上有錯誤，那麼B（這是後退）開始進行。現在，只要A發生錯誤B被調用正常，但是A在訂閱者上調用onComplete（），所以B響應即使B執行成功，也不會到達用戶。這是正常的行爲？我認爲onErrorResumeNext（）應該繼續流並通知用戶一旦完成，如文檔（https://github.com/ReactiveX

0熱度

1回答

如何使用Observable.onErrorResumeNext來執行分支並傳播異常

我有以下可觀察鏈，A-> B，其中A在DB中創建一個條目，B將一個作業排入rabbitMQ。我想要做的是有第三個C運行，當且僅當B拋出一個異常（它必須刪除/還原輸入到數據庫中的數據）。該異常應該傳播給調用者。我正在使用onErrorResumeNext，但似乎工作，只有當我有一個明確的（空）訂戶。注意：下面代碼中的委託返回A並且queueSender返回B.這是正確的，還是有更好的方法來做到這一點

1熱度

2回答

防止觀察對象被啓動，除非另一個觀察對象完成它的工作

在我的應用程序中，客戶端使用由Observable支持的服務。每個服務調用都是基於會話的，因此必須在調用業務服務方法之前啓動會話。爲了初始化會話，我做了一個Observable這樣做。我的問題是，無論何時客戶端並行使用多個業務服務，會話初始化都會被重複。客戶端代碼與會話無關。我需要一種初始化會話的方式，以便只能調用一次會話（當第一個業務服務方法被調用時）。基本上所有後續的業務觀察員都必須等待條件

1熱度

1回答

按順序「拆分」/「生成」操作？

我試圖在RxJava中找到適合下一個序列操作的操作： [A]，[B]，[C] - > Aa，Ab，Ac，Ba，Bb，Bc，Ca ，Cb 這個實際的用例是我有一個Observable，它包含了我試圖轉換成Observable的條目列表，這些條目從列表中發射出來。像這樣： Observable<List<Item>> ---> Observable<Item> 我似乎無法找到一個合適的RxJav

0熱度

1回答

改造，觀察到的，由於簡單的界面永無止境的代碼

： public interface Api { @Get("/{id}") Observable<Person> getPerson(@Path("id") String id); } ，並像一個電話： api.getPerson("me").toBlocking().single(); 一切正常，除了我的應用程序不會終止。如果我完成訂閱Observable並取消訂

1熱度

1回答

如何創建一次發出項目，然後從BehaviorSubject onComplete的Observable？

我需要從BehaviorSubject<Observable<T>>創建Observable<T>。創建的observable只能發射一次，然後調用onComplete()。有沒有辦法做到這一點？謝謝！編輯 private BehaviorSubject<Observable<T>> subject = BehaviorSubject.create(); public Observabl

0熱度

2回答

供給Observable的值

我是rxjava的新手，我有以下問題：對象被外部系統不規則地放入FIFO隊列中。我需要一個每秒運行的Observable，從隊列中取出一個項目（如果有的話）併發送給訂閱者。兩個問題：隊列中的項目中產生，同時可觀察是活的，它是不可能提供前期的所有項目。隊列可能爲空，在這種情況下，Observable必須處於待機狀態並且不會發射任何東西。（如果Observable會在暫停後的隊列中有一個項目可