rx-java2

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呼叫用戶。

-1熱度

1回答

SocketTimeoutException由RxJava未處理

我有一個使用sdk版本25開發的Android項目。我使用RXJava作爲我的線程管理和Retrofit庫來打網絡。我還實現了用於添加重寫有趣攔截（鏈：Interceptor.Chain）的自定義攔截器：響應？ { val request = addHeader(chain) val response = chain.proceed(request) checkErrorR

0熱度

1回答

如何使用Retrofit2和RxJava2拋出自定義異常

使用Retrofit2和RxJava2時，拋出自定義異常有問題。改造阿比定義 public interface BackendInterface { @Headers({"......"}) @POST("international-services/") Observable<BackendResponse> post(@Body BackendRequest