RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
RxJava 代码中出现编译失败“无法找到 concatMap 的符号”
我是 RxJava 编码语言的新手。 我正在尝试编写一个函数，以递归方式从一个 S3 位置复制文件并将内容粘贴到另一个 S3 位置。 这是我的代码
我要解决的问题用以下代码表示： @测试 公共无效 buffer_shouldZipAllTheThings() 抛出 InterruptedException { 最终 CountDownLatch 闩锁 = 新 CountDownLat...
我想了解 rxjava 合并是如何工作的。所以这里是简单的代码，应该合并 2 个可观察量的结果并发送给订阅者 Observable.merge(getObservable(), getTimedObservabl...
我想用RxJava实现以下目标： 缓冲元素并在最后一个元素过去 5 秒后发布它们 在第一个元素之后的 20 秒内发布缓冲元素 呃...
我有一个 Rx 流，它向观察者发送多个项目。 但我想修改发回的第一个项目。所有其他项目都可以按原样发送。 我知道 map() 会介入...
我有BehaviorSubject，我想知道如何获得以下行为： 当出现 False 时，应等待 10 秒才能发出值 当为 True 时，它立即发出值...
使用 UseCase 将 Rx Observable 转换为 Flow
我正在尝试将我的代码转换为 Compose。我有库，但都有 Observable 类型，不能与 Flow 一起使用。我需要 Flow 中的结果。 受保护的抽象 Observable UseCase();
我有以下方法使用 otto 和 AsyncTask 向 UI 发布响应。 private static void onGetLatestStoryCollectionSuccess(final StoryCollection StoryCollection, Final Bus 总线) { 新
从 Vert.x 4.5 开始，我应该使用什么来代替已弃用的 `Vertex#rxExecuteBlocking`？
从 Vert.x 4.5.0 开始，Vertx#rxExecuteBlocking（以及返回 Maybe 的executeBlocking 签名）已被弃用。 我应该如何从 Vert.x Future（使用 Vertx#executeBlocking）转向
在 RxJava 中组合 2 个数据源，可以从 1 个可观察量中获取新数据
我目前正在开发一个 Android 应用程序，我在 ViewModel 中使用 RxJava 来处理来自本地 Room 数据库和远程 API (Retrofit) 的数据。我已经实现了拉动刷新功能...
我正在尝试为返回 RxJava Maybe 对象的方法创建注释。 因此，在拦截方法中的 MethodInterceptor 类中，我尝试访问从 M...
无法为 io.reactivex.Observable 创建调用适配器
我将向我的服务器（它是 Rails 应用程序）发送一个简单的 get 方法，并使用 RxJava 和 Retrofit 获取结果。我所做的事情是： 我的界面： 公共接口 ApiCall { 字符串
“它不是重复的”理由 StackOverlow 告诉我，我需要编辑我的问题并解释为什么提议的重复项（及其相应的接近投票）不相关......
我正在尝试学习 RxJava 并浏览一些内容。我经历过这个例子，订阅者在订阅 observable 后很快就取消订阅。 公共静态无效主（字符串[]参数...
我有 [1,2,3,2,4,5,0,2,1,3,4,5,2,2,1,4,5] 我想要的输出是 [[1,2,3,2,4,5],[1,3,4,5],[1,4,5]] 这意味着我想从输入序列中提取带有一些开始标记的块，这里 1，一个...
工作管理器与反应式扩展（Rxjava）有什么区别？我应该使用什么或何时使用？
最近我了解了工作管理器，现在我想澄清一下何时需要使用响应式扩展或工作管理器。
我在我的项目中使用 Rx+Retrofit。将创建所谓的 API 缓存来保存失败的 POST 请求。然后我需要再次发送缓存的请求。那么处理不同队列的最佳方法是什么...
我在我的项目中使用 Rx+Retrofit。将创建所谓的 API 缓存来保存失败的 POST 请求。然后我需要再次发送缓存的请求。那么处理 N 量
我在我的项目中使用 Rx+Retrofit。将创建所谓的 API 缓存来保存失败的 POST 请求。然后我需要再次发送缓存的请求。那么处理 N 量
请有人解释一下使用反应式的优点是什么： Observable 问候 = Observable.just(“你好”); Observable 大喊大叫=greeting.map(s -&g...