RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我正在研究RxJava。我为可观察类创建了一个布尔值真值和假值的随机流。可观察的类应在X随机秒后重新获得（x在10秒和...之间）...] >>
我无法进入ReactiveX的心态，或者我正在使用的代码库编写得不好。假设我有一些Observable A（），并且我需要另一个Observable B（）的数据才能执行...
从其他来源构建时出现Java / RXJava3错误[关闭]
C：\ Users \ Admin \ Desktop \ ExternalPlugins-master \ PerfectSpec \ src \ main \ java \ net \ runelite \ client \ plugins \ perfectspec \ MenuEntrySwapConsumer.java：47：错误：无法访问Consumer eventBus.subscribe（。 。
我正在尝试为Vertx Web客户端编写一个包装，以使用来自Reactstream的Publisher使用服务器从服务器加载响应主体：import org.reactivestreams.Publisher;导入io.vertx.reactivex.ext.web ....
我有一个列表，我正在通过flatMapIterable对其进行迭代。但是，如果要在迭代之间加入一些特定元素，我想中断迭代。例如。 val list = Single.just（listOf＆...
我最近在我的项目中添加了Hengam SDK；但不幸的是，我不能再使用RxJava，它会导致重复的异常。值得一提的是，在将SDK添加到项目之前...
将Flowable分成2个，处理2个流，但是一个依赖于另一个？
我有以下情况：我需要处理以Flowable形式接收的流。流上的每个项目都有一条数据，只有流上的第一个元素包含元数据。 ...
我有一个用例，我想将Observable 的数据与Maybe 的最新值进行合并。带有Maybe的API是我无法控制的外部API。 ...
如何使用RxJava / Rx Android Kotlin实现Internet Android的检查？
检查互联网的答案早在2014年发布在这篇文章中：https://stackoverflow.com/a/27312494/12359431但是，在其中一个答案中，这段代码很有趣...
我需要以4,8,12,16 ...秒的特定间隔运行2个作业，而另一个是5,9,13,17 ...秒。我在RxJava中使用了Interval运算符。作业B需要在作业A之后运行。作业B应该睡眠...
我试图用Intellij打开一个Maven项目。该项目最初是在eclipse上创建的，并且运行良好。但是我收到未找到错误依赖性'io.reactivex.rxjava2：rxjava：2.2.19'（...
MissingBackpressureException：由于缺少请求而无法发出缓冲区
我已经收到包含MissingBackpressureException的错误报告：由于缺少对RxJava Flowable的请求，因此无法发出缓冲区，但是我正在努力创建一个简单的测试用例……
我查询youtube api，并制作了多个模型以使用gson转换器映射json。现在，我想使用存储库模式并统一数据库和远程数据库的返回值，但是我有一些...
目前，我正在学习rx / dart。但是我很挣扎。有什么办法可以使此属性同步？等待currentUser（）迫使我做使该属性异步。但是我需要一些...
我需要编写一个将字符串作为输入的函数，然后生成两个文件，并将它们压缩在一起。对于非反应性代码，它将是：void func（String input）{byte [] a = ...
如何从可观察的值返回到JavascriptInterface方法？
我需要从联系人中返回值，这些值可以通过电话从手机上检索到。问题在于返回值。我在桥中有下一个方法：@JavascriptInterface public ...
我正在尝试实现以下行为：定期轮询/生成事件流（持续时间短，例如1秒），然后根据某些内部特征对事件进行分组。每个组...
我正在尝试在Android应用程序中使用RxJava以及Retrofit与RESTful API进行交互。在我的Android应用中，我在各种UX事件中发出了许多请求。如果...
我正在尝试通过使用crunchLast阻止纯/纯RxJava的快速点击。下面的代码执行得很好，但是从未调用过blockSubscribe代码块。我想念什么吗？我不是...
我想使用RxJava和RxAndroid进行以下异步网络调用。我在项目依赖项中包括了最新的RxJava（3.0.1）和RxAndroid（3.0.0），但仍然得到...