RxJava - Just vs From
在以下情况下，我使用 Observable.just 和 Observable.from 时得到了相同的输出： public void myfunc() { //swap out just for from here and i get the same results,why ? ...
使用Kotlin协程（Flow）的PublishSubject
我曾使用一个PublishSubject，并向其中发送信息，同时也在监听结果。这个方法一直运作良好，但现在我不确定如何使用Kotlin的协程（flows或channels）做同样的事情。private val subject = PublishProcessor.create<Boole...
将可观察对象转换为列表。
我正在使用RxJava。 我有一个Observable<T>，如何将其转换为List<T>？ 看起来这是一个简单的操作，但我在网上找不到任何相关信息。
RxJava：尝试将错误传播到Observer.onError时发生错误。
我在Rx Library中遇到了IllegalStateException错误，不确定问题的根源是在RxJava还是我可能正在做某些不正确的事情。 当进行证书固定（在所有服务器请求上都会发生）时，致命崩溃似乎指向会话超时或注销然后重新登录。复现步骤（大约25％的时间会发生）如下：登录，打开列...
我需要取消完成的可观察对象吗？
如果一个可观察对象完成了，我是否仍需要取消订阅/处理（在RxJava2中）以移除观察者（防止内存泄漏），或者一旦发生onComplete或onError事件，RxJava会在内部处理它呢？ 其他类型如Single、Completable、Flowable等呢？
如何在RxJava（Android）中正确处理onError？
我正在获取设备上已安装应用程序的列表。这是一项耗费昂贵的操作，所以我正在使用 Rx 进行操作： Observable<List> observable = Observable.create(subscriber -> { List result = g...
RxJava和观察者代码的并行执行
我正在使用RxJava Observable API编写以下代码：Observable<Info> observable = fileProcessor.processFileObservable(processedFile.getAbsolutePath()); obse...
当使用 Retrofit 2.0 Observables 时出现错误，如何获取响应体？
我正在使用Retrofit 2.0进行调用返回Observables的api。当调用成功且响应符合预期时，一切都很好。现在假设我们有一个错误响应，它会抛出onError。即使响应是错误的，我也想读取响应正文。 示例@FormUrlEncoded @POST("tokenLogin") Obs...
如何从Android的OnClick事件创建一个可观察对象？
我是新手，对响应式编程不熟悉。因此，当我从事件（如onClick、ontouch）创建流时，遇到了问题。 有人能帮我解决这个问题吗？ 谢谢。
RxJava引入了Single<T>。我该如何将Observable<T>转换为Single<T>?
RxJava最近引入了Single。有没有一种方法可以将已经存在的Observable（几乎就是Single）转换为Single，而不修改原始observable的源代码？ 例如，我有一个api服务类，其中包含一个返回Observable的方法，该方法基本上是从远程资源获取用户。假设我无法修...