RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
使用Android Studio 3.0在Kotlin中使用RxJava zipWith IDE
我想创建一个Observable，它发出一些来自和Observable的项目，包含具有Interval Observable的对象列表，这样第一个observable中的项目就会发出一些......
我是新的rxjava2.when我读了关于它的书，我有一些我不明白操作员延迟。我们可以使用delay（）运算符推迟排放。它将保留任何收到的排放......
我有以下代码private void tryToLauch（）{try {launch（）; } catch（MyException e）{postError（e.getErrorMessage（））; e.printStackTrace（）; ...
使用RX Observables并行多个REST API调用
我试图使用Observables调用REST API并行。我面临一些问题。我在这里描述了问题。有人可以帮我吗？我的用例是，我有5个customerid，我需要......
所以我使用带有Rx的MVVM模式，就是当我运行假设在后台线程中运行我的UI线程被阻塞的操作时，这是我的viewmodel：class dataViewModel（...
我正在尝试创建一个从firebase查询返回列表的observable。问题是当我调用onNext发出Item然后onComplete时它会停止发出第一个项目之后的项目，......
BehaviorSubject vs PublishSubject
我试图了解关于：什么时候使用BehaviorSubject的黄金法则（如果有的话）？什么时候使用PublishSubject？他们之间的区别非常明显有很多......
假设我有一个可流动的，一些视图被订阅并且它正在收听变化。我想添加一个自定义方法，仅基于flowable的第一个发射，但也保持...
在RxJava中有5种不同的调度程序可供选择：immediate（）：创建并返回一个在当前线程上立即执行工作的Scheduler。 trampoline（）：创建并返回...
我正在使用RxJava CombineLatest和两个observable。我的问题是，如果其中一个observable以onError结束，是否会调用onNext组合？文档显示了两者的快乐场景......
我有一个Android应用，其中有多个A类型的观察者，这些观察者订阅了多个B类型的Observable。 ...
在Apache Flink测试中是否存在虚拟时间的概念，就像在Reactor和RxJava中一样
在RxJava和Reactor中，有一种虚拟时间概念来测试依赖于时间的运算符。我无法弄清楚如何在Flink中做到这一点。例如，我把以下内容放在一起......
我尝试为NuProcess创建rx包装器，用于异步执行外部进程的库。这里主要类 - 与流程“沟通”。这里我读了stdout：静态类ProcessHandler ......
我的事件来自系统的快速时间，但我只需要每500毫秒持续一次，所以我使用tthrottle。但是在用户输入之后，我想为1个事件禁用throtle以使其继续...
RxJava`Completable.andThen`没有连续执行？
我有一个用例，我在一个Completable中初始化一些全局变量，并在链的下一步（使用andThen运算符）我使用这些变量。以下示例解释了我...
我有一个非常大的数据集合，原始数据已经按照什么是关键进行排序。例如，我有一个CSV文件，第一列将成为分组的关键。 ...
Rxjava with Retrofit save在后台发送文件中的数据
我是Rxjava和RetroFit的新手。我有一个问题。我使用以下代码从服务器获取数据。 ApiUtils.getMainRestService（mContext）.getMain（URL）。 subscribeOn（调度程序....
我正在开发一个Android应用程序。我想在UI中显示两个值。这些值是从API服务器检索的，我正在使用Retrofit来获取它们。这是我的ApiService接口（Retrofit）：...
我已经开始在android中再次编程，因为在过去的4年中它已经发生了很大的变化，我有点困惑。我试图从服务器异步加载我的数据...
如何创建Observable并使用Retrofit稍后更新它们RxJava？
基本上我需要创建一个没有初始值的Observable列表。我订阅了Observables列表，并根据所有Observables的回复提供所需的结果。我用 ...