rx-java

5熱度

2回答

如何使用Java 9 Flow Interfaces /將它們包含在Java 9中有什麼意義？

首先，我必須說，我對反應式編程沒有多少經驗。由於JDK 9（Flow and its nested interfaces）中只有幾個接口，因此JDK 9顯然不包含像RxJava這樣的反應式庫。在Javadoc中，有一些用於實現Publisher,Subscription和Subscriber的示例。但這些似乎是相當低級的，沒有任何反應式操作員或處理背壓。那麼將這些接口包含到JDK中有什麼意義

0熱度

3回答

哪個庫我應該使用RxAndroid和RxJava

我想使用RxAndroid和RxJava，但我有點困惑哪些下面提到的庫我應該使用？在一些教程它們使用例如以下類其可在 compile 'io.reactivex:rxandroid:1.2.1' compile 'io.reactivex:rxjava:1.1.9' .subscribe(new Subscriber<String>) 和一些教程哎使用例如它們使用下列類，其是可以在以下

0熱度

2回答

如何根據一組值更新數據模型

該方案是基於整數值的Set更新列表中的數據模型。例如有一個ArrayList： Student { name: "abc", id: 1, hasPassed: false }... 現在我有一個整數集，基本上在其內部具有學生ID {1，2，...}通過學生表示學生證。我得到Student arrayList onNext我的observer方法。如何根

0熱度

1回答

RxJava。加入來自兩個Observable/Flowable流的所有項目

我正在加載一些項目以在單個網頁上顯示。與此同時，我正在加載物品的價格。簡化它看起來像這樣： Observable<Integer> ids = itemIdsToShow(); // COLD Observable Observable<Item> items = ids.flatMap(id -> loadingItem(id)); Observable<Price> prices = id

0熱度

1回答

節流在RxJava

節流規則：如果在最近的100毫秒發出沒有其他項目，下一個項目將被交付立即訂戶如果沒有，緩衝傳入的項目，直到1000毫秒超時或緩衝區大小達到500，然後提供緩衝項目清單給用戶 RxJava可以實現這個嗎？

0熱度

1回答

Vertex HttpCllentRequest重定向

我們如何處理vertex HttpClientRequest中的重定向（302響應代碼）。是否有可能啓用vertx本身來處理重定向，或者我們必須明確處理。請解釋如何做到這一點，以防它需要明確地完成。

0熱度

1回答

RxJava 2 - 如何鏈接異步電話

我剛剛開始學習RxJava，所以如果我要求一個新手問題，請不要將它釘死在十字架上，但我已經花了好幾天的時間來嘗試解決這個問題，但沒有取得任何成功。我已經閱讀了幾乎所有我能找到的文檔，並沿着大多數關於http://reactivex.io/tutorials.html的教程進行了跟蹤。我搜索了StackOverflow和互聯網的其他高低，但顯然我似乎是這個星球上唯一有這個問題的人。這很奇怪，因爲它基

0熱度

1回答

如何進行兩次翻新調用併合並結果？

我一直在瀏覽StackOverflow和其他Android相關的網站，試圖抓住這一點，但我仍在掙扎。我使用改造如下做出的API調用： public interface TheMovieDbApi { @GET("genre/{type}/list") Observable<GenresReply<Genre>> getGenreList(@Path("type") String type)

0熱度

1回答

在SplashActivity中處理多個TCP和HTTP響應

我應該在SplashActivity中組織2個HTTP（Retrofit + Rx）和2個TCP（KryoNet）請求。當我從所有請求得到響應時，我應該啓動MainActivity。如何組合請求，處理響應，然後開始MainActivity？親愛的開發者，請幫助我。我目前正與琥珀金協議（https://github.com/kyuupichan/electrumx/blob/master/docs

0熱度

1回答

代碼爲301和200

兩次打電話GET方法我有一段代碼，它使用RxJava zip()操作同時執行兩個獨立的呼叫我的REST API： @Override public void onItemSelected(AdapterView<?> parent, View view, int position, long id) { Observable<List<Player>> obs_pl