rx-java2

0熱度

2回答

我有用於套接字通信的自定義Rx適配器。在它之外，我觀察到Flowable帶有消息。然後我有一些經理處理每個消息，然後進一步發佈它。 fun observeSocket() = socketManager .observe() .doOnNext{ insideMessageHandler.handle(it) } 然後，我

0熱度

1回答

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

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

0熱度

1回答

HttpException未被onError（）

捕獲我正在向使用Retrofit2和RxJava2的後端服務器發出請求。當答案是200或201時，一切正常。當服務器的響應爲409或503並且引發HttpException時，它不會被Observable的onError()捕獲，並且應用程序崩潰。，我想提出的要求是這樣的： @POST("users/sign-up") fun register(@Body register: Register

0熱度

1回答

RxJava2在toList之後沒有收到doOnNext

我正在開發一個項目，在該項目中，我想在返回結果之前迭代列表併合並它們。基本上我試圖將PostResponse對象轉換爲Post。一些相關的代碼。 Post.java public class Post { @NonNull private User user; @NonNull private String title; @NonNull private Strin

0熱度

1回答

在RxJava2中沒有實現onError錯誤，即使它實現

因此，我有一個非常基本的RxJava觀察器流的工作流，其中我要求改進的東西，成功的響應我吐司成功味精和錯誤我吐司錯誤味精。我以下，參照的情況是錯誤的情況下我期望從API錯誤味精，我將其轉換成用戶可讀取單詞而顯示爲Toast，如下圖所示，當我使用doOnNext和doOnError方法這種方式，與錯誤崩潰提及。我已經添加了throwExceptionIfFailure方法，它顯示了我如何轉換可讀

1熱度

1回答

如何在android房間和rxjava 2中插入數據並獲取id作爲輸出參數？

插入查詢 @Insert(onConflict = OnConflictStrategy.REPLACE) long insertProduct(Product product); //product id is auto generated 視圖模型 public Completable insertProduct(final String productName) { retu

1熱度

1回答

如何使用Flowable.generate從科特林

這裏是在Flowable.generate一個失敗的短線嘗試（與更多類型的註釋比我正常使用）： val xs: Flowable<String> = Flowable.generate<Int, String>( java.util.concurrent.Callable<Int> { -> 0 }, io.reactivex.functions.BiConsumer<Int,

0熱度

1回答

使用rxjava處理兩個身份驗證請求

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

-2熱度

1回答

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

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

2熱度

1回答

可配置資源 - 設計模式

首先是背景位。我們正在開發一個應用程序，它接收來自n號碼sources的消息。 source可能是messaging queue，FTP位置，webservice調用特定服務或任何可能的編排層，我們可以想到。我已經被賦予了一個任務來設計和開發一個模塊，它將充當一個可配置的資源管理器，它將在處理消息的模塊和發送消息的應用程序之間工作。能否請您提出任何設計模式或任何可以在此使用的最佳實踐。我們希望