RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我在我的数据库（房间）中添加一条记录，它返回插入记录的 ID。例如，我添加一行并返回数字 5（这是一个 Long）。 当该操作完成时，我 n...
如何使用 Flowable 和 Single 并行运行一组可调用对象
我有 4 个阻塞操作，我想使用 RxJava Single/Flowable 并行运行它们。 我编写的用于检查并行性的测试代码是： 最终单 f1 =单.
使用原生 Android API 实现外设 1 并使用 RxAndroidBle 实现外设 2 可能的冲突
我正在处理使用原生 BLE API 编程的代码。它有自己的发送/写入特性的队列实现。但我也需要实现第二个外围设备
如何从 Flowable 中删除存在于第二个 Flowable 中的元素？
我需要保存一些数据做数据库。 我有从服务器获取的数据的 Flowable，以及来自我的数据库的数据的 Flowable。 我只需要保存数据库中尚不存在的数据。 我试着去...
如何在 Android Studio 的视图模型中将这个数据类带到这些函数中
所以这是一个我正在进行的项目，我想保持项目的结构完整。我想我的 API 调用是正确的，因为该项目使用的是 RxJava。我的问题是解除校准...
我一直在使用 JUnit 5 和 Mockito 对我将向您展示的以下代码进行单元测试，但它无法正常工作。我想评估成功的案例。 公共也许<
RxJava。为什么 timer()、delay() 等运算符默认使用计算调度程序？
CPU密集型任务需要计算调度器，那么为什么RxJava要在delay()、timer()、interval()等操作符中使用它来延迟呢？ 延迟是 CPU 密集型任务吗？我们可以...
我们的应用程序要求每 12 小时对我们的数据库执行一次更新，这需要：下载数据 -> 处理它 -> 将它写入 Realm 数据库 目前我们的实现...
我想遍历域名列表（数百万条记录），发送请求并接收响应，以确定它是否存活。 我选择了一种被动的方法，我
我正在尝试在后台线程上将一些数据插入到本地数据库中，并在我的 ViewModel 的构造函数中使用 Completeable 公共 MainViewModel() 扩展 ViewModel { 公开
Realm：使用 Clean-Architecture 和 RxJava2
一些上下文，我尝试将一些干净的架构应用于我的一个项目，但我在存储库的（领域）磁盘实现方面遇到了问题。我有一个存储库，它可以提取 som...
Rxjava - 组合 Singles 并生成数据类 Single
我有一个关于单身的问题，但还没有找到一个好的答案。 我必须从获得 2 个 Single 源的方法中返回 Single。问题是我需要使用输出...
在 Android studio java 中将 AsyncTask 转换为 RxJava
首先，我是 android studio 上的 java 新手，并尝试使用 asyncTask 使用来自 github 的代码。但是 AsyncTask 已被弃用，因此需要根据我的情况将其替换为 rxJava
Youtube 和 Google Chrome 在安卓手机上不断崩溃
我是使用android 12 的android 用户。今天更新youtube、chrome 和google 后，我发现当我尝试打开应用程序时我的youtube 和chrome 一直崩溃。我试过重装，cl...
我有一个包含对象的flux请求。任务是创建（如果不存在）或更新（如果存在）这些对象。我已经尝试过实现这个功能，如下所示： requestFlux.flatMap(entry -> { ...
我有一个问题，就是把一个对象发布到多个方法中。我的代码简化版如下：包 org.example.reactive; import lombok.extern.slf4j.Slf4j; import reactor.core......
所以我有一个函数，使用RxJava进行调用，然后这个函数应该将返回的元素插入到一个列表中。所以代码工作正常。我能够检索和所有的项目在...。
RxJava 单独过滤一个列表对象内部并返回其对象与过滤后的列表。
我正在使用RxJava2（Single）与retrofit进行网络请求，当接收响应时，amog对象包含的其他字段，有一个对象列表，我试图实现的是过滤 ...
我的工作是在Http SSE流，我必须保持http连接活着。为此，我每15秒发送一个空消息（命名为心跳，其他的都命名为真实事件）。源.map(....
我正试图在Java中的websockets之上实现一个请求->响应层。我最近偶然发现了RxJava，它似乎是一个很好的库。下面是我目前的方法...