reactive-streams
-
-
使用反应器的 Flux.buffer 进行批处理工作仅适用于单个项目 我正在尝试用于从数据库批处理加载。 用例是,从数据库加载记录可能是“突发的”,我想引入一个小缓冲区,以便在可能的情况下将负载组合在一起。 我的概念方法是使用某种形式的处理器
-
RxJava 2.0 - 如何将 Observable 转换为 Publisher 如何在RxJava版本2中将可观察转换为发布者? 在第一个版本中,我们有 项目,完全可以满足我的需求。但是我该如何在RxJava 2中做到这一点呢?
-
无功流和无功流有什么区别? 我试图理解Reactive和ReactiveStreams之间的区别,特别是在RxJava的上下文中? 我能弄清楚的最多的是,Reactive Streams在规范中有一些背压的概念,但这已经存在于RxJava/Reactive的接口中。 不介意ELI5的
-
如何正确调用 Akka HTTP 客户端来处理多个 (10k - 100k) 请求? 我正在尝试使用Akka HTTP 2.0-M2编写一个用于批量数据上传的工具。但我面对的是 触发一批请求的正确方法是什么?我计划执行 10 000 - 100 000 个请求的批次。
标签