rx-java2

0熱度

3回答

我想使用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回答

DisposableCompletableObserver泄漏即使我正在清除CompositeDisposable

我是RxJava和LeakCanary的新手，因此這可能是簡單的事情（希望）。基本上我有一個活動，其中包括一個CompositeDisposable。我得到了我的Singleton存儲庫的實例，並使用它來獲取Completable，並將其添加到CompositeDisposable。在onPause中，我清除了CompositeDisposable，這讓我相信會避免調用對象（在本例中爲Acti

2熱度

1回答

用Dagger 2和RxJava2包裝SharedPreferences

我是否需要包裝Android SharedPreferences類？如果是的話，你能否給我一個簡單的工作例子？我知道如何使用SharedPreferences，但是當涉及到包裝它併爲它提供Dagger 2和RxJava2時，我很困惑。

1熱度

2回答

RxJava1到Rxjava2遷移錯誤

轉換RxJava1代碼RXJava2給予這個錯誤，不知道我做錯了無類型變量（一個或多個）R的實例（S）存在，使得單>符合ObserableSource API調用 @GET("/search/users?per_page=2") Observable<UsersList> searchGithubUsers(@Query("q") String searchTerm); @GET("htt

1熱度

2回答

Android RxJava2應用程序在創建observable時調用emitter.onError（）時崩潰

我在create()的幫助下手動創建Observable。現在裏面，我檢查一些條件&基於此，我想通知用戶有關錯誤。以下是我正在創建觀察到： public Observable<User> loginUser(String email, String password) { return Observable.create( emitter -> { myAsync

2熱度

3回答

在RxJava2中使用flatMapIterable（）

我剛剛開始使用RxJava並嘗試一個示例項目。我試圖做到的，是 - >獲取一個對象 - > 其中包含的子對象的列表 - >檢查子列表滿足謂詞條件 - >併發出子-objects如果滿足這是我的POJO public class UpComingMovies { @SerializedName("results") private List<Movies> results; }

2熱度

1回答

java.lang.NoClassDefFoundError：okhttp3.OkHttpClient $生成器

我發現了same issue，並與指定的解決方案嘗試，但仍然我得到了同樣的錯誤，如下 java.lang.NoClassDefFoundError: Failed resolution of: Lokhttp3/OkHttpClient$Builder; Caused by: java.lang.ClassNotFoundException: Didn't find class "okhttp

-1熱度

1回答

取消長時間運行的任務內部Observable內置訂閱處置

我正在寫一個被動的封裝在凌亂的庫上以輕鬆地在我的應用中發送http請求。這裏是類： /** * Used to send a http GET/POST request. */ public class BasicRequest { public static final String LOG_TAG = "BasicRequest"; public static final int

2熱度

3回答

在Spring中創建新實例和使用範圍原型註釋之間的區別

我的應用程序正在偵聽交換（使用rabbitMQ），期望收到一些API數據，然後將其重定向到相關位置。我使用rxJava來訂閱這些更改，當目的是通過創建RestClient每次打開一個新線程併發送請求時 - >它將接收數據，解析它，發送它，然後發送迴應隊列。我的問題是，我想每次創建我的RestClient的新實例。使用彈簧範圍註釋的想法：@Scope(value = ConfigurableBe