将AsyncTask转换为RxAndroid
我有以下的方法，使用otto和AsyncTask将响应发布到UI。private static void onGetLatestStoryCollectionSuccess(final StoryCollection storyCollection, final Bus bus) { ...
如何在Activity中使用Retrofit和RxJava/RxAndroid处理旋转？
我看到这里的文章提到，我们可以使用一些全局缓存来处理旋转。 您可以使用缓存或重放Observable操作符来防止此问题，同时确保Observable以某种方式在Activity生命周期中幸存下来（例如，将其存储在全局缓存中，在Fragment中等） 但是如何实现呢？有人可以指导我如何做...
使用Reactivex的Consumer接口
我刚接触ReactiveX，正在通过阅读源代码进行学习。一切都很清晰，但突然出现了一个名为“Consumer”的接口，它被用来代替Observer。 有人能告诉我它到底是做什么的吗？ 我查了几个链接，但它们只说了一句话：Consumer是一个接受单个值的函数接口（回调）。 我想知道它的确...
如何忽略错误并继续无限流？
我想知道如何忽略异常并继续无限流（在我的情况下，是位置流）？ 我正在获取当前用户位置（使用Android-ReactiveLocation），然后将其发送到我的API（使用Retrofit）。 在我的情况下，当网络调用期间发生异常（例如超时），会调用onError方法并停止流。该如何避免这...
安卓如何在旋转设备时处理多个请求，使用RxJava管理。
我正在使用android应用的MVVM架构，我想在设备旋转时管理请求和rxJava，请问如何在设备旋转后禁止请求并从上一次请求继续执行？ 这是我的简单代码，但我找不到任何关于它的文档和示例代码。 @Override public void onCreate(@Nullable Bundle...
RxJava中的Observable.just和Single有什么区别？
我是RxJava和RxAndroid的新手，正在努力理解Observable.just和Single之间的区别。看起来每个都旨在为其观察者发出一个项目。 以下是我的简单Android活动代码，其中包含两个按钮。第一个按钮创建一个Observable，第二个按钮创建一个Single：findV...
Retrofit结合Rxjava使用时，Schedulers.newThread()和Schedulers.io()的区别是什么？
在Retrofit网络请求中，使用 Schedulers.newThread() 和 Schedulers.io() 有什么好处？我看到很多示例使用 io()，但我想了解原因。 示例情况：observable.onErrorResumeNext(refreshTokenAndRetry(ob...
使用RxJava获取对象，转换包含列表，并使用该列表。
我试图解决的高级问题是，使用RxJava将从FooContainer（Observable）获取的包含Foo对象的列表转换为FooBar对象的列表。 我的（困惑的）尝试： fooContainerObservable .map(container -> container.get...
RxJava/Android: 结合两个相关的Observables的结果
我有两个Observables。 Observable<A> getAObservable() 返回类型为 A 的 Observable。 Observable<B> getBObservable(A) 返回类型为 'B' 的 Observable。 在这里，O...
使用Retrofit和RxJava的concatWith方法时出现堆栈溢出错误
我希望使用rxjava Observable在Retrofit中处理分页。我遵循另一个问题中的建议。我需要获取超过100个页面，但是在第20页左右链条失败并且停止了对可观察对象的任何进一步订阅，日志如下所示：04-04 04:12:11.766 2951-3012/com.example...