RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我有以下代码：repo.getObservable（）.timeout（1，TimeUnit.MINUTES）.subscribeOn（Schedulers.io（））.observeOn（AndroidSchedulers.mainThread（））....
为什么下面的代码不发出任何结果？该主题出了什么问题？我希望我订阅的那一刻会得到结果，即我声明的长度。 val subject = ...
我有2个数据类：GitResult数据类GitResult（@SerializedName（“ total_count”）@Expose var total_count：Int，@SerializedName（“ incomplete_results”）@Expose var ...
我想按如下方式构建可切换的可迭代流（Observable >）：订阅时，发出空的可迭代（例如List）。在收到输入时（PublishSubject？），将其添加...
我有一个可观察的序列。当插入第一个元素时，我想启动一个计时器，并在计时器的时间范围内对随后插入的元素进行批处理。然后，计时器将无法启动...
我是Rx Java的新手，我想从多个API中获取数据。这些API彼此独立，但是我想在View中显示这些API的数据。所以我想做...
我已经在互联网上进行搜索，但是找不到关于此的最新示例。关于这个问题，github上的大多数研究对象和实例都是4岁。这就是为什么我决定要...
如何将Function3转换为并行打2个API，而不是3个或更多？
我正在使用以下方式并行命中3个API，因为我想看到像Function4、5、6，如果您想命中更多API但没有Function2 那么如何使用命中2个API？ ...
在我的项目中，我从XML报告中检索操作列表，并将新操作上载到Firebase。这很好用：//每次查看Observable时都要经过de XML报告并发出一个节点。...
RxJava中的线程安全是SerializedSubject必需
我在RxJava中创建了一个Subject实例，并从多个线程调用其onNext（）：PublishSubject subject = PublishSubject.create（）; // ... subject.onNext（“ A”）; //线程主题。...
如何使用Observable.zip（…）来获取API响应？
我必须点击3个API才能更新同一屏幕，因此，我认为RxJava是并行执行此操作的最快方法。在搜索实现时，我遇到了Observable.zip（...）...
RxJava为列表中的每个项目通过Android中的Retrofit发出api请求
我的Android项目中存在以下问题：我有一个元素列表（ArrayList），该列表是从上一个使用Retrofit进行网络调用获得的。 CategoryItem看起来像这样：公共类CategoryItem ...
在Android中使用RxJava窗口或缓冲区进行批处理吗？
我希望在api帖子之前实现批处理机制，以进行一些简单的事件收集和记录。由于这是Android设备，因此我也想处理此服务的生命周期事件...
我有一个实体列表List 像公共类Entity1 {private int id; ....}我需要遍历该列表，应用我的函数并获取Mono 基于...
Android ConnectException错误-EHOSTUNREACH（到主机没有路由）错误
我一直在尝试请求Google Cloud函数，但出现此错误作为返回：无法从/ 2804：18：6a：4d76：3730：279a（端口，连接到2800：3f0：4001（端口443） 44968）120000ms之后：...
在我的视图模型中，我有一个使用协程调用API的函数。有趣的loadPosts（）{GlobalScope.launch（coroutineContext）{changeState（load = true）val list = withContext（...
我经常发现自己创建的流取决于Single 提供的某些条件。考虑下面的示例：@Test public void test（）{Observable.range（0，10）....
[[RxJava]如何通过Android RxJava上的`retryWhen（）`处理网络错误×Retrofit2
我正在尝试对RxJava进行翻新的https请求，当网络不可用时，我要这样处理。 1，检查网络状态。 2，如果网络可用，请重试请求3，如果网络不可用...
Observable，当没有订阅者时会缓冲项目，然后在订阅时释放它们并清除缓冲区？
我想要一个可观察的对象：可以按需发出项目并且从不真正完成（热的可观察对象？）知道何时有订阅者，如果没有订阅者，它将缓冲我告诉它的项目...