rx-java2

0熱度

1回答

我有一個包含登錄頁面的項目。在這個頁面上，用戶點擊「登錄」後，我需要發送請求到checkUserName（檢查我們是否有這樣的用戶，他可以登錄），然後才能進行身份驗證。在代碼中，我有這樣的：接口： @POST("endpoint") Flowable<AccountResponse> auth(@Body AuthRequestBody authRequestBody); @POST("

-2熱度

1回答

如何在用戶完成輸入後使用RxJava2輸入輸入值

在我的Android應用程序中，我必須通過運行非常複雜的計算來處理用戶輸入。所以我想在用戶閒置一段時間後運行它。例如。用戶輸入123，然後停止輸入。我想在輸入3時運行計算，而不是在1或2之後運行。如何使用RxJava2執行此操作？

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

0熱度

1回答

RxJava 2入門：連續執行任務。 `然後'或'推遲'？

我想在RxJava中連續運行兩個步驟。我想第1步之前完成像2開始： step 1: start step 1: finish step 2: start step 2: finish 我嘗試不同的API變化和RxJava運行並行我的兩個步驟，這是不是行爲，我想： step 1: start step 2: start step 2: finish step 1: finish

0熱度

1回答

使用RxJava的同步序列

我在如何使用RxJava表達以下方面掙扎。讓我們想象一下我的包列表中的流，我想在網絡上傳輸： PublishSubject<List<Packet>> packetsSubject = ...; 而且我有以下傳輸功能： public Observable<Status> transmit(Packet p) {...} 我想傳遞一個列表，每包只要包的返回狀態是Status.OK。換句話說，

2熱度

3回答

從正確的線程調用RxJava2可以取消/拋棄

我正在實現一個可觀察的來自Resource的線。問題是，這個資源真的不喜歡從它創建的不同線程中關閉（它會殺死一隻小狗並在發生這種情況時拋出一個異常）。當我處理認購，資源Cancellable/Disposable從main線程中調用，而觀察到的是訂閱的Schedulers.io()。這裏是科特林代碼： fun lines(): Observable<String> = Obser

0熱度

1回答

RxJava超時沒有退訂源

我訂閱熱可觀察，然後應用timeout運營商，但我不想取消訂閱TimeoutException時，只產生特殊項目（我知道源將最終發出新的項目）。我怎樣才能做到這一點？我試圖結合超時與onErrorReturn但這又導致onComplete呼叫用戶。