与RxJava2相关的任何内容 - JVM的RxJava Reactive Extensions的新实现 - 一个使用Java VM的可观察序列组成异步和基于事件的程序的库。
说我想在用户按下按钮时从我的Android应用发送网络请求。我正在使用RxJava，因为如果用户再次点击发送请求，我想取消上一个请求，所以我需要使用...
我试图使用RxJava多线程加快计算速度，但是并行计算比顺序计算要花更多的时间。我在数组中有数百个值。对于每个值，我都需要做长...
我的应用程序弹出ANR（应用程序没有响应）对话框。长期以来，我一直在努力解决这个问题。我做了很多优化，最后我的主线程占用了2到300万个...
我正在尝试在Vert.x的一个垂直版本中使用RxJava2：import io.reactivex.Completable;导入io.vertx.core.Promise;公共类MainVerticle扩展了io.vertx.reactivex.core.AbstractVerticle {...
Rxjava Scheduler.trampoline与concatmap
似乎基于文档，Scheduler.trampoline确保元素发出先进先出（即按顺序）。似乎concat映射的目的是要确保所有内容都已对齐...
将对象的Single转换为RxJava中同一对象的内部字段的Single
我有一个用户模型，该模型嵌入了特征模型public class User {private List cracteristics; }使用Flowable和rxJava，我想转换一个Single [
如何在RxJava中更改“ RoomDatabase和翻新”
我正在使用存储库模式。我想实现一个逻辑，如果内部DB中没有值，则返回Api Response的值并将其插入内部DB中。收到...
我正在自我介绍RxJava2，但我感觉自己做错了。就我而言，我想执行以下一些异步操作。在此示例中，第一步是检查...
对单个Observable的并行map（）操作，并接收乱序的结果
给定一个Observable 和一个映射函数Function 昂贵，但是需要可变的时间，有没有办法在多个...上并行调用映射函数...
RxJava上的运算符Observable / Flowable延迟发射n个项目
我想对Flowable进行转换，以使其延迟发射项目，直到收集到指定数量的项目为止，然后按照FIFO顺序将它们发射到下游，以保持恒定的延迟项目...
我有以下代码：repo.getObservable（）.timeout（1，TimeUnit.MINUTES）.subscribeOn（Schedulers.io（））.observeOn（AndroidSchedulers.mainThread（））....
我正在尝试在具有searchView的地方实现一个应用程序，当用户搜索某些内容时，这些应用程序将调用改造请求，该请求将返回可观察的数据。在myRepository中，我将...
在函数方法中，我抛出nullPointerException并打印出线程计数（sout（Thread.activeCount）。似乎每次我重试错误时，threadCount都会增加1。为什么是...
我正在尝试使用Retrofit和rxjava关闭来自http请求的流，这是因为它超时，或者因为我需要更改进入请求的详细信息。两者似乎都起作用...
为什么下面的代码不发出任何结果？该主题出了什么问题？我希望我订阅的那一刻会得到结果，即我声明的长度。 val subject = ...
我有以下一段代码Single.just（settings.toString（））.observeOn（AndroidSchedulers.mainThread（））.subscribe（new SingleObserver （）{private Disposable一次性； ...
[RxJava订阅添加到CompositeDisposable之后不起作用
我正在将RxJava Flowable与Room一起使用，在这里我听表中的更改。提到的问题是，当将订阅的结果（即一次性的）添加到CompositeDisposable时，它会立即...
我想按如下方式构建可切换的可迭代流（Observable >）：订阅时，发出空的可迭代（例如List）。在收到输入时（PublishSubject？），将其添加...
我有一个可观察的序列。当插入第一个元素时，我想启动一个计时器，并在计时器的时间范围内对随后插入的元素进行批处理。然后，计时器将无法启动...