rx-java

0熱度

1回答

Kotlin：如何將使用Thread.sleep的測試轉換爲RxJava TestScheduler

我正在編寫一個工具測試，它檢查是否將某些東西緩存到Rx緩衝區中，並且在某段時間（10秒）後，此Subject將緩衝值插入到我的房間數據庫。當我使用Thread.sleep（syncTimeInterval）時，測試是正確的。我想用TestScheduler編寫相同的測試。這是用了Thread.sleep版本（通過測試）： @Test fun testMultipleLogs() {

0熱度

2回答

保持區間可觀察運行中的Java

我新用Java線程，並想知道我怎麼能牢記以下可觀測運行， private void init() { System.out.println("Running..."); Observable o = Observable.interval(5, TimeUnit.SECONDS) .flatMap(o -> serverService.listServers("

0熱度

1回答

RXJava邏輯圖鏈

我有以下代碼寫在RXJava中。 validateProduct(payload) .map.(r -> { if(r.getBoolean("valid")){ return createProduct(productPayload); }else{ return null; // request.end() | end the chain here

1熱度

1回答

的DatePicker與數據綁定和Rxjava可觀測視圖不保存到境界上不同的Android版本

下面運行該代碼與Android版本SDK 16.但是一個機器人仿真器以某種方式，當它運行在與Android版本> 21，數據綁定與境界模擬器儲蓄不被觸發.. 我應該如何與Android版本來處理？是因爲所呈現的UI在不同的Android版本不同，所以數據綁定不會有任何的工作？這裏這段代碼視圖模型 @PerFragment public class OnboardDOBViewModel ex

0熱度

1回答

從AsyncTask到RxJava的改造請求週期

如何從AsyncTask（從doInBackground方法）將以下代碼更改爲RxJava？ MessageRq rq = new MessageRq(); rq.setId(id); Call<MessageRs> response = App.getApi().getFirstCommand(rq); nextLink = getNextUrl(response, rq); for (

0熱度

1回答

使用實時數據更新Recycler視圖

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

2熱度

1回答

使用反應流的無源拉式背壓

這是我對該主題的理解。有出版商和訂閱者。爲發佈者和訂閱的僞碼是一樣的東西， Publisher{ Subscriber s; subscribe(Subscriber s){ this.s = s; s.onSubscribe(new Subscription(){ onRequest(int n){ List<Mess

1熱度

2回答

如何使Observable在1秒的時間間隔後發出字符

我剛剛開始使用RxJava/android並開始練習並開始使用我希望使每個1秒都能發出字符串的字符，我該怎麼做？以下是我迄今爲止嘗試過，它只是發出串一次： Observable<String> myObservable = Observable.interval(5000L, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedulers.ma

0熱度

1回答

RxJava：範圍運算符不工作

爲了實踐目的，我創建了stream/Observable，它以1秒週期發射值，其發射值以一秒爲間隔，但在發射6後不會終止/停止，它會繼續發射值。 Observable myObservable = Observable.range(1, 6) .interval(5000, TimeUnit.MILLISECONDS) .observeOn(AndroidSchedul

0熱度

1回答

RxJava：如何使可觀察的創建不同於主線程的線程

我想要可觀察的代碼在不同於主線程的線程上運行。我怎樣才能做到這一點，我在做這樣的： Observable operationObservable = Observable.create(new ObservableOnSubscribe() { @Override public void subscribe(ObservableEmitter e) throws Excep