rx-android

-1熱度

2回答

我試圖實現獲取當前位置。我已經使用這兩個代碼。 mFusedLocationClient = LocationServices.getFusedLocationProviderClient(this); mFusedLocationClient.getLastLocation()... 定位精度2000米和 ReactiveLocationProvider locationProvide

0熱度

1回答

代碼適用於RX Completable not blocked onSubscribe thread

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

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熱度

2回答

RxJava Single.create無法指定線程

在initialize（）方法的下面工作很好，但它必須與其他調用在同一個io線程（ioScheduler）上工作。 fun initialize(): Single<Boolean> { return Single.create { callback -> callback.onSuccess(true) } } 我試圖將其更改爲下面的代碼： intern

0熱度

2回答

RxJava 2運營商組合，只提供第一個值從一堆

這個想法是，當我多次呼叫publishSubject.onNext(someValue)我只需要得到一個值，如debounce運算符，但它提供了最後一個值，我需要跳過所有值除了第一組之外，直到我停止呼叫onNext()持續1秒。我試過使用類似throttleFirst(1000,TimeUnit.MILLISECONDS)的東西，但它不像debounce那樣工作，它只是在每次交付後使窗口和1秒後

2熱度

1回答

Observable.just VS單在RxJava

我是新來RxJava和RxAndroid，並試圖瞭解Observable.just和Single之間的差異。它看起來每個都被設計爲爲其觀察者發射一個項目。這裏是我的簡單的Android活動的有兩個按鈕的代碼。第一個按鈕創建一個Observable，第二個按鈕創建一個Single： findViewById(R.id.just).setOnClickListener(view -> Observa

0熱度

1回答

在RxJava2中沒有實現onError錯誤，即使它實現

因此，我有一個非常基本的RxJava觀察器流的工作流，其中我要求改進的東西，成功的響應我吐司成功味精和錯誤我吐司錯誤味精。我以下，參照的情況是錯誤的情況下我期望從API錯誤味精，我將其轉換成用戶可讀取單詞而顯示爲Toast，如下圖所示，當我使用doOnNext和doOnError方法這種方式，與錯誤崩潰提及。我已經添加了throwExceptionIfFailure方法，它顯示了我如何轉換可讀

0熱度

1回答

使用實時數據更新Recycler視圖

我有一個實時更新對象的列表（每秒一次）。我已經設計我的應用程序使用MVVM架構和Android數據綁定庫我已經將視圖模型綁定到視圖，並且每次重新加載活動時都會更新正常，但無論如何都要通知視圖模型該模型數據已經更新並且實時更新視圖？我已經嘗試過實現BaseObservable接口和ObservableFields，但我仍然得到相同的結果。可能還有一些RxJava技術，我可以用我雖然不熟悉RxJ