rx-java

-1熱度

1回答

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

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回答

代碼適用於RX Completable not blocked onSubscribe thread

我有一些傳統的非RX代碼，通過產生一個新的Thread來完成一些網絡工作。工作完成後，它會在回調中調用一個方法。我無法控制此代碼運行的線程。這是遺產，它自己產生了一個新的Thread。 interface Callback { void onSuccess(); } static void executeRequest(String name, Callback callbac

2熱度

1回答

有沒有辦法重構這個RxJava代碼？

我有我的訂閱可觀察看起來像： compositeDisposables.add(githubService.getRepos() .subscribeOn(Schedulers.io()) .observeOn(AndroidSchedulers.mainThread()) .subscribe( (List<Github

0熱度

1回答

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

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

0熱度

1回答

Rx：強制可觀察至少需要N秒才能完成

我正在爲我的應用製作啓動畫面。我希望它在進入主屏幕前至少持續N秒。我有一個Rx變量myObservable從服務器或從我的本地緩存中返回數據。我如何強制myObservable在中完成至少N秒？ myObservable // .doStuff to make it last at least N seconds .subscribe(...)

0熱度

1回答

RxJava：循環中的異步調用

我有一個整數列表和每個整數，我想從數據庫中獲取一個字符串值，並將其放入一個Map中，其中整數是來自父列表的整型值，並且字符串是從數據庫中獲取的字符串值。我也想要獲取並行運行的字符串。這是我用RxJava實現的。我的代碼工作，我得到了預期的結果，但我不認爲提取名稱並行運行。 public Observable<Map<Integer, String>> getVitalsForConnectedD

0熱度

2回答

RxJava單/接口

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

0熱度

3回答

http post response is null

我發送http post請求給REST API，我從服務器獲得狀態ok響應，但是在這個腳本中，它總是運行'myError'函數。在後端，一切運行良好，沒有任何錯誤。在錯誤函數中，響應值仍未定義。 var toDoApp = angular.module('toDoApp'); toDoApp.factory('registrationService', function() { var re