rx-java

3熱度

2回答

我對Rx編程非常陌生，我在項目中嘗試瞭解它。我要的是我有如下GamesInfoList的對象： @AutoValue public abstract class GameInfoList { public static TypeAdapter<GameInfoList> typeAdapter(Gson gson) { return new AutoValue_GameIn

0熱度

1回答

在Observable的onSuccess（）或onError（）之後執行方法嗎？

很多時候我需要在我的應用中顯示一些加載行爲，並且我想在工作完成後解僱它 - 無論結果是成功還是錯誤。因此，我結束了這樣的代碼： addDisposable(router.launchHomepage() .compose(loadingView.show())) .subscribe( { loadingView.dismiss() }, {

1熱度

2回答

使用Reactivex的消費者接口

我是ReactiveX的新手。我從源代碼中學習它。一切都很清楚，但突然之間我得到了一個名爲「消費者」的詞，這是一個界面。它被用來代替Observer。有人可以讓我知道它到底做了什麼嗎？我跟隨了幾個鏈接，但他們只是說了一條語句Consumer是一個接受單個值的函數接口（回調函數）。我想知道它的確切工作。這是什麼？我們爲什麼需要它？如何使用它？它代替觀察者嗎？如果是，如何和爲什麼？

0熱度

2回答

調用鏈inifnitely

我有需要的輸入，並返回一個輸出服務： Item callService(Item input); 輸入始終是由可觀測和服務調用的輸出應該是下一個發射元件發射的前一個元素由可觀察的。這個順序應該重複，直到一個項目達到一定的條件。其實，我有一棵樹的葉子，我把葉子發送給一個服務，告訴我它的父類是什麼。我繼續這樣做直到我到達根部。我的第一個解決方案：我遞歸調用一個函數flatMap。我不喜歡這樣

1熱度

2回答

調用擴展功能的任何RX操作

我創建了一個擴展功能， fun <T> Observable<T>.subscribeWithErrorHandling(onNext: (T) -> Unit ,onError: ((throwable: Throwable) -> Unit)? = null): Subscription { //doing stuff } 在科特林級，我將能夠使用它沒有問題，以這種方式 observ

0熱度

2回答

RxJava 2.重試與延遲，同時繼續是不同的其他項目

我已可觀察到的，從很多渠道獲得項目： Source { List<Item> data } 來源和項目之間的關係是多到許多和不同來源項目可能會重複自己。項目是應該上傳到服務器的實體，服務器不接受重複項目。爲了達到這個目的，我將資源合併到他們的ID中，然後將唯一的項目上傳到服務器。如下圖所示： Observable.merge(source1(), source2(), source3())

1熱度

1回答

爲什麼PublishSubject不會發出第一個元素

我嘗試使用rx和PublishSubject。所以我創建對象： PublishSubject<MyEvent> events = PublishSubject.create(); ，在我服務，我擺在那MyEvent。 events.onNext(new MyEvent); 所以有時候我沒有收到第一個事件，但第二次我接收。有時我會收到所有的事件。任何人都可以解釋一下，這裏有什麼問題？

0熱度

1回答

Android我的代碼rxjava緩慢工作

在我的應用程序中有一種通過API獲取數據的方法。它在IntentService中執行。接收到的數據被寫入數據庫。我在rxjava的幫助下重寫了這個方法，但執行時間大大增加了。這是我在IntentService代碼 Call<List<DocLine>> DocLineResult = mApi.getDocLine(UserID, LastUserDate); Response<List<Do

1熱度

2回答

使用RxJava 2.x有可能使用Zip超過2個Observable嗎？

我正在使用RxJava 2.x，並有3個observable（如果重要，特別發佈主題）。我喜歡一次運行它們，並獲得一次結果。我使用Observable.zip()運營商爲這種過程。但是，它看起來像Zip運算符不支持2個以上的觀察值。是否還有其他操作符可以像zip一樣組合3個以上的可觀察對象？ Observable.zip( getData(), getOtherData(

1熱度

1回答

如何將自定義pojo作爲參數傳遞給rxjava2 Observable中的接口方法調用？

當前代碼 Observable.from(listMovie)//list of movie .flatMap(new Func1<Movie, Observable<FavMovieRes>>() { @Override public Observable<FavMovieRes> call(Movie movie) { retur