RxJava调度器的使用场景
在RxJava中，有5种不同的调度器可供选择： immediate()：创建并返回一个调度器，该调度器立即在当前线程上执行工作。 trampoline()：创建并返回一个调度器，该调度器将工作排队在当前线程上，在当前工作完成后执行。 newThread()：创建并返回一个调度器，每个工作...
何时在Android中使用RxJava，何时使用来自Android架构组件的LiveData？
我不明白在Android中为什么要使用RxJava和LiveData（来自Android Architectural Components）。如果能够以代码示例的形式解释它们之间的用例和区别，那将非常有帮助。
使用Retrofit 2.0和RxJava获取响应状态码
我正在尝试将我的Android项目升级到Retrofit 2.0并添加RxJava。我正在进行API调用，并希望在服务器返回错误响应时检索错误代码。Observable<MyResponseObject> apiCall(@Body body); 在 RxJava 调用中：myRe...
无法为io.reactivex.Observable创建调用适配器。
我将使用简单的get方法向我的服务器（它是一个Rails应用程序）发送请求，并使用RxJava和Retrofit获取结果。我所做的事情如下： 我的接口：public interface ApiCall { String SERVICE_ENDPOINT = "https://198....
RxAndroid：SubscribeOn 和 ObserveOn 有什么区别？
我正在学习Rx-java和Rxandroid2，不太清楚SubscribeOn和 ObserveOn之间的主要区别。
将一个Observable列表合并，并等待所有Observable完成
TL;DR 如何将Task.whenAll(List<Task>)转换为RxJava？ 我的现有代码使用Bolts来构建异步任务列表，并等待所有这些任务完成后执行其他步骤。本质上，它建立了一个List<Task>并返回一个单独的Task，当列表中的所有任务都完成时标记...
Retrofit结合Rxjava使用时，Schedulers.newThread()和Schedulers.io()的区别是什么？
在Retrofit网络请求中，使用 Schedulers.newThread() 和 Schedulers.io() 有什么好处？我看到很多示例使用 io()，但我想了解原因。 示例情况：observable.onErrorResumeNext(refreshTokenAndRetry(ob...
如何使用RxJava 2的CompositeDisposable？
在RxJava 1中，有一个叫做CompositeSubscription的类，但是在RxJava2中已不再存在，而它的替代品是rxJava2中的另一个类——CompositeDisposable。那么我该如何使用CompositeDisposable或Disposable呢？
如何忽略错误并继续无限流？
我想知道如何忽略异常并继续无限流（在我的情况下，是位置流）？ 我正在获取当前用户位置（使用Android-ReactiveLocation），然后将其发送到我的API（使用Retrofit）。 在我的情况下，当网络调用期间发生异常（例如超时），会调用onError方法并停止流。该如何避免这...
RxJava合并不同类型的可观测对象
我刚开始学习rxjava。我需要将发出不同类型对象的两个observables组合起来。类似于Observable<Milk> 和 Observable<Cereals> 并得到一个 Observable<CerealsWithMilk>。我找不到适用于这种...