java - 将 CompletableFuture 与 RxJava 抽象结合使用

标签 java asynchronous rx-java

在 Web 应用程序中将 CompletableFuture 与 RxJava 抽象结合使用是一个好习惯吗?如果没有,一起使用这些东西我可能会遇到什么样的问题?

另外,我还想知道,根据最佳实践,RxJava 使用什么样的抽象来使我的代码不仅是响应式的,而且是异步的?

最佳答案

RxJava 提供了一些方法来自然地弥合 Rx 和使用 Future 的代码之间的差距:

io.reactivex.Observable.fromFuture(Future<? extends String>, Scheduler)
io.reactivex.Single.toFuture()

我相信 RxJava3 添加了对 CompletableFuture 更好的支持,但我还没有尝试过:

https://github.com/ReactiveX/RxJava/wiki/What's-different-in-3.0

关于java - 将 CompletableFuture 与 RxJava 抽象结合使用,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/61255652/

相关文章:

android - 为什么 RxJava 中的 take(5) 运算符返回所有对象

android - 将 Firebase 任务<Void> 包装到 RxJava CompletableEmitter 中?

Apache Camel是什么

java - 使用 JSQLParser 从项目中选取多个

javascript - nodejs 将相同的参数异步到函数数组?

c# - 如何从 WCF 获取数据(异步)?

java - 为什么不调用 doOnDispose?

java - Hibernate 查询在论坛问题中搜索内容

java - 如何使jar文件在启动时运行

javascript - 这种情况下如何实现回调函数