rx-java2

-1熱度

1回答

我正試圖執行一個拋出異常的函數。 Observable.fromCallable { foo() } .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .take(1) .onErrorReturn { /* onError operation *

0熱度

2回答

如何爲Recyclerview的每個項目分別請求？

我有一個RecyclerView和它所代表的數據列表。我從包含唯一標識的服務器/數據庫中獲取數據，基於這個項目標識我想向服務器/數據庫發出請求，並且想要在RecyclerView上顯示它。我正在提出一個單獨的請求，我想請求儘可能多的項目，因爲它在屏幕上可見。我已經定義了10個項目，我從服務器接收並顯示他們，但對於每一個項目，我需要更多的細節做額外的請求，並顯示在同一個屏幕在onBindVie

1熱度

1回答

防抖動單位無視超時測試

我有這樣的方法來從API public void fetchSearchResults(Observable<String> searchObservable) { searchObservable .filter(search -> !TextUtils.isEmpty(search)) .debounce(700, TimeUnit.MILLISECONDS)

1熱度

2回答

RxJava：如何預先startWith（）默認發射EVERY TIME父親observable發射？

即時通訊試圖有一個模式，在這裏我觀察到其產生的一些對象，轉化成域事件，如開始，成功，周圍觀察到的產emited錯誤，如果是有道理的 public Observable<BookRenderingEvent> extractAndRenderObservable(String epubPath) { return extractObservable(epubPath) .

1熱度

2回答

BlockingGet塊UI線程RxJava 2

我正在處理這個問題。我試圖打電話RxJava在同步方式，但是這樣做的結果阻斷主線程。這裏是我的代碼 @Override public Single<SettingsBundle> getSettings() { SettingsBundle settingsModel = mSettingsManager.getSettings(); return Singl

0熱度

1回答

如何對兩個可觀察對象使用自定義合併函數

我有兩個觀察對象發出相同的數據類型。我需要把它們合併 Single<Post.List> postsRecent = getRecentPosts() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()); Single<Post.List> postsPopular

0熱度

2回答

RxJava單/接口

的可觀回報的實現我還面臨着有趣的問題我有以下方法 @Override public Single<IResults> getResults() { return Single.just(new ConcreteResults()); } IResults是一個接口，ConcreteResults是落實。但是我得到一個錯誤 Error:(149, 27) error: inco

0熱度

1回答

RxAndroid - 使用Zip操作符處理錯誤

我試圖找到一種並行執行請求的方法，並在每個observable完成時處理它們。儘管所有的觀察對象都給出了迴應，但所有事情都能正常工作，但在完成所有事情時我沒有辦法處理所有的錯誤。這是拉鍊運算符，它基本上並行地執行2名的請求的示例： Observable.zip( getObservable1() .onErrorResumeNext { errorThrowab

1熱度

1回答

RxJava2將兩個Flowables合併爲一個

我很努力地找到任何將兩個Flowable合併成一個的RxJava2實例。我想修改包括沿 Integer[] ints = new Integer[count]; Integer[] moreints = new Integer[count]; Arrays.fill(ints, 777); Arrays.fill(moreints, 777); Fl

0熱度

2回答

如何使用RxJava獲得來自Realm的物品列表的Observable？

我只有這個： public Observable<List<Movie>> getAll() { return Observable.just(Movie.class) .flatMap(t -> Observable.just(t) .doOnSubscribe(disposable -> realm.executeTransaction(realm1