RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。
我需要严格地一一处理不同类型的事件，但是在后台线程中。 下一个代码根据文档下一个代码 Schedulers.from(executor, false, true); ...
io.reactivex.exceptions.UndeliverableException 异常无法传递给消费者，因为它已经取消/处置了
使用 completable 时出现 UndeliverableException 公共可完成的createBucketWithStorageClassAndLocation（）{ 返回 Completable.complete() .doFinally(() -> { ...
尝试通过 RxJava 中的 ZipOutputStream 进行压缩时，Zip 内容已损坏
我正在尝试创建一个 zip 文件并通过分段上传路由将该 zip 文件上传到 AWS S3 中。但是，我面临一个问题，文件已成功生成，但是内容
反应流（monix）运算符组合，用于缓冲具有重叠元素的时间跨度
我有一个连续发射的 Observable[T] ，我想要一个 Observable[List[T]] ，它为源发射的每个元素在指定持续时间内发射最后一个元素。例子 可观察到的。范围...
Reactive Streams 是围绕背压构建的，这很棒，我想更好地了解如何使用 RxJava3 API。删除 GUI 事件溢出数据的方法非常好，但如果我
我需要实现以下行为： 发出 REST 发布请求 如果响应返回状态为 429 Too much requests，则最多重试 3 次，延迟 1 秒 如果第三次重试失败或出现任何情况
如何使用 java-rx 在 Observable 中重试错误？
我正在尝试学习Reactive X Java，并且我真的很难理解错误处理的工作原理。我想要实现的很简单：一个 Observable 生成一个数据流，并且偶尔可能
在我的项目中我想使用分页3。 在将分页添加到我的项目中之前，我可以从服务器获取数据并显示到我的 RecyclerView 中 但添加分页后我遇到了这个问题： 在我的...
分页库在向上滑动刷新后只调用LoadInitial，不会调用LoadAfter
我正在尝试使用分页库+ RxJava 创建应用程序，一切正常，它从后端加载数据并将其插入到我的 Recyclerview 中，当我向下滚动 LoadAfter 正常加载下一页时，我的问题...
RxJava 迭代列表，为每个项目调用 API，并返回列表作为结果？
我必须调用一个返回一个对象的API，并且在这个对象内部有一个列表。 对于此列表中的每个项目，我必须检索项目详细信息。要检索详细信息，我必须制作异步 API ca...
Schedulers.io() 和 Schedulers.computation() 有什么区别
我在 couchbase 中使用 Observables。 Schedulers.io() 和 Schedulers.computation() 有什么区别？
在 Android 中使用 RxJava、OkHttp 和 Okio 下载进度
在我们的应用程序中，我使用此代码下载了一个图像文件。我需要在用户界面上显示下载进度（下载字节数百分比）。如何在此代码中获取下载进度？我寻找解决方案，但是
我的 Observable 订阅如下所示： compotoDisposables.add(githubService.getRepos() .subscribeOn(Schedulers.io()) .observeOn(
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();