rx-java 相关问题

从其他来源构建时出现Java / RXJava3错误[关闭]

C：\ Users \ Admin \ Desktop \ ExternalPlugins-master \ PerfectSpec \ src \ main \ java \ net \ runelite \ client \ plugins \ perfectspec \ MenuEntrySwapConsumer.java：47：错误：无法访问Consumer eventBus.subscribe（。 。

来自Vertx Webclient响应主体的响应流发布者

我正在尝试为Vertx Web客户端编写一个包装，以使用来自Reactstream的Publisher使用服务器从服务器加载响应主体：import org.reactivestreams.Publisher;导入io.vertx.reactivex.ext.web ....

打破flatMapIterable循环RXJava

我有一个列表，我正在通过flatMapIterable对其进行迭代。但是，如果要在迭代之间加入一些特定元素，我想中断迭代。例如。 val list = Single.just（listOf＆...

不能与Hengam SDK一起使用RxJava

我最近在我的项目中添加了Hengam SDK；但不幸的是，我不能再使用RxJava，它会导致重复的异常。值得一提的是，在将SDK添加到项目之前...

将Flowable分成2个，处理2个流，但是一个依赖于另一个？

我有以下情况：我需要处理以Flowable形式接收的流。流上的每个项目都有一条数据，只有流上的第一个元素包含元数据。 ...

从Rx获取最新数据，可能在Rx可观察的变化时

我有一个用例，我想将Observable 的数据与Maybe 的最新值进行合并。带有Maybe的API是我无法控制的外部API。 ...

如何使用RxJava / Rx Android Kotlin实现Internet Android的检查？

检查互联网的答案早在2014年发布在这篇文章中：https://stackoverflow.com/a/27312494/12359431但是，在其中一个答案中，这段代码很有趣...

在RxJava中创建同步间隔

我需要以4,8,12,16 ...秒的特定间隔运行2个作业，而另一个是5,9,13,17 ...秒。我在RxJava中使用了Interval运算符。作业B需要在作业A之后运行。作业B应该睡眠...

无法从intellij的pom文件添加RXjava依赖项

我试图用Intellij打开一个Maven项目。该项目最初是在eclipse上创建的，并且运行良好。但是我收到未找到错误依赖性'io.reactivex.rxjava2：rxjava：2.2.19'（...

MissingBackpressureException：由于缺少请求而无法发出缓冲区

我已经收到包含MissingBackpressureException的错误报告：由于缺少对RxJava Flowable的请求，因此无法发出缓冲区，但是我正在努力创建一个简单的测试用例……

如何将变量从可观察变量转换为其他可观察类型

我查询youtube api，并制作了多个模型以使用gson转换器映射json。现在，我想使用存储库模式并统一数据库和远程数据库的返回值，但是我有一些...

Dart Rx删除等待中

目前，我正在学习rx / dart。但是我很挣扎。有什么办法可以使此属性同步？等待currentUser（）迫使我做使该属性异步。但是我需要一些...

rx-java创建两个文件，并从字符串输入中压缩它们

我需要编写一个将字符串作为输入的函数，然后生成两个文件，并将它们压缩在一起。对于非反应性代码，它将是：void func（String input）{byte [] a = ...

如何从可观察的值返回到JavascriptInterface方法？

我需要从联系人中返回值，这些值可以通过电话从手机上检索到。问题在于返回值。我在桥中有下一个方法：@JavascriptInterface public ...

使用RxJava将无限个分组事件流写入旋转文件中

我正在尝试实现以下行为：定期轮询/生成事件流（持续时间短，例如1秒），然后根据某些内部特征对事件进行分组。每个组...

以类似队列的方式使用RxJava并暂停/启动队列

我正在尝试在Android应用程序中使用RxJava以及Retrofit与RESTful API进行交互。在我的Android应用中，我在各种UX事件中发出了许多请求。如果...

通过纯RxJava实现防止快速点击

我正在尝试通过使用crunchLast阻止纯/纯RxJava的快速点击。下面的代码执行得很好，但是从未调用过blockSubscribe代码块。我想念什么吗？我不是...

RxJava Android：观察者不兼容类型错误

我想使用RxJava和RxAndroid进行以下异步网络调用。我在项目依赖项中包括了最新的RxJava（3.0.1）和RxAndroid（3.0.0），但仍然得到...

Android-RxJava：使用可观察的方式从后台线程更新UI

我刚刚开始构建一个简单的Android应用，其中我想在后台线程中发出网络请求，然后使用服务器响应来更新主线程（UI线程）。到目前为止，我使用了...

是将常规闭包转换为RxJava可以使用的形式的正确方法

我刚刚开始考虑将RxJava V3与Groovy v3结合使用。自然，我倾向于从Closures开始。但是RxJava的subscription（）方法不接受它们。所以我实现了一个...