rx-java 相关问题

RxJava - JVM的Reactive Extensions - 一个库，用于使用Java VM的可观察序列组合异步和基于事件的程序。

如何使用rxjava从SWT表中获取选定的项目？

events swt rx-java

回答 1 投票 0

在滤波rxjava

Throwable.stacktrace()

android rx-java

回答 1 投票 0

如何在 RxJava 中对两个 Single<Optional<>> 值求和

如何在Java 11中总结两个Single>？我正在使用 RxJava，但我认为这没有任何意义。例如：单>第一个=

java java-stream rx-java option-type java-11

回答 1 投票 0

RxJava3 group通过发出单独的组而不是按键分组

正在将我的应用程序从 RxJava2 更新到 RxJava3。我通过阅读文档知道 groupBy 的工作原理有一些更新，但我无法理解为什么我会看到这种行为......

android rx-java rx-java3

回答 1 投票 0

合并Flowable与通过批量anyc操作更新的过滤元素

我有 rxjava3 Flowable 具有 Item 对象，并且希望仅对匹配条件的元素批量运行异步操作。然后我想允许下游运算符迭代原始 Item

java rx-java rx-java3

回答 1 投票 0

RxJava + Retrofit 2 链接 API 请求

我需要通过将多个改造 API 调用链接在一起来创建一个可观察对象。我有 2 个服务：ItemService 仅包含项目名称和 id，而 ItemDetailsService 包含许多其他

android rx-java retrofit2 dagger-2

回答 3 投票 0

如何测试一个方法，什么结合了RxJava和Suspend的乐趣？

所以我有一个简单的测试，我尝试测试错误结果，如下所示： @测试有趣的`测试`() { 每个 { Util.fetchLocation()} 返回 Single.error(Exception()) 瓦尔

android rx-java mockk

回答 1 投票 0

如何公平地处理多个订阅？

我需要以严格的一一方式处理不同类型的事件，但是在后台线程中。根据文档，下一个代码 Schedulers.from(executor, false, true); 应该 ...

java rx-java rx-java3

回答 1 投票 0

RxJava 3：如何公平地处理多个订阅？

我需要严格地一一处理不同类型的事件，但是在后台线程中。下一个代码根据文档下一个代码 Schedulers.from(executor, false, true); ...

java rx-java rx-java3

回答 1 投票 0

io.reactivex.exceptions.UndeliverableException 异常无法传递给消费者，因为它已经取消/处置了

使用 completable 时出现 UndeliverableException 公共可完成的createBucketWithStorageClassAndLocation（）{ 返回 Completable.complete() .doFinally(() -> { ...

java rx-java rx-java2 reactivex rx-java3

回答 4 投票 0

尝试通过 RxJava 中的 ZipOutputStream 进行压缩时，Zip 内容已损坏

我正在尝试创建一个 zip 文件并通过分段上传路由将该 zip 文件上传到 AWS S3 中。但是，我面临一个问题，文件已成功生成，但是内容

java stream zip rx-java zipoutputstream

回答 1 投票 0

反应流（monix）运算符组合，用于缓冲具有重叠元素的时间跨度

我有一个连续发射的 Observable[T] ，我想要一个 Observable[List[T]] ，它为源发射的每个元素在指定持续时间内发射最后一个元素。例子可观察到的。范围...

scala observable rx-java reactive-programming monix

回答 1 投票 0

Flowable rxjava3 中的无界背压

Reactive Streams 是围绕背压构建的，这很棒，我想更好地了解如何使用 RxJava3 API。删除 GUI 事件溢出数据的方法非常好，但如果我

rx-java backpressure rx-java3

回答 1 投票 0

如何测试Spring WebClient何时重试？

我需要实现以下行为：发出 REST 发布请求如果响应返回状态为 429 Too much requests，则最多重试 3 次，延迟 1 秒如果第三次重试失败或出现任何情况

rx-java reactive-programming project-reactor spring-webclient

回答 3 投票 0

如何使用 java-rx 在 Observable 中重试错误？

我正在尝试学习Reactive X Java，并且我真的很难理解错误处理的工作原理。我想要实现的很简单：一个 Observable 生成一个数据流，并且偶尔可能

java rx-java

回答 1 投票 0

MVP 中的 Paging3 和 Rxjava 问题

在我的项目中我想使用分页3。在将分页添加到我的项目中之前，我可以从服务器获取数据并显示到我的 RecyclerView 中但添加分页后我遇到了这个问题：在我的...

android rx-java android-paging-3 android-paging-library

回答 1 投票 0

分页库在向上滑动刷新后只调用LoadInitial，不会调用LoadAfter

我正在尝试使用分页库+ RxJava 创建应用程序，一切正常，它从后端加载数据并将其插入到我的 Recyclerview 中，当我向下滚动 LoadAfter 正常加载下一页时，我的问题...

android rx-java android-architecture-components android-paging-library

回答 1 投票 0

RxJava 迭代列表，为每个项目调用 API，并返回列表作为结果？

我必须调用一个返回一个对象的API，并且在这个对象内部有一个列表。对于此列表中的每个项目，我必须检索项目详细信息。要检索详细信息，我必须制作异步 API ca...

android rx-java

回答 1 投票 0

Schedulers.io() 和 Schedulers.computation() 有什么区别

我在 couchbase 中使用 Observables。 Schedulers.io() 和 Schedulers.computation() 有什么区别？

observable rx-java scheduler

回答 2 投票 0

在 Android 中使用 RxJava、OkHttp 和 Okio 下载进度

在我们的应用程序中，我使用此代码下载了一个图像文件。我需要在用户界面上显示下载进度（下载字节数百分比）。如何在此代码中获取下载进度？我寻找解决方案，但是

android rx-java okhttp okio

回答 3 投票 0

rx-java 相关问题

最新问题