project-reactor 相关问题

Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。

Schdulers.elastic未在Reactor中创建新线程

我正在尝试创建一个流，其中一个磁通量并行发射10个项目，每个项目休眠1秒。由于每个项目都是在单独的线程上发布的，因此我希望整个过程都需要...

spring-boot project-reactor spring-reactive spring-reactor

回答 1 投票 0

助焊剂发生器-没有可用数据时如何处理？

问题：当没有更多数据时，我们如何处理通量发生器？我正在使用Project Reactor的Flux API轮询Redis中的数据（通过外部服务）。这需要是...

java spring-boot microservices project-reactor reactive-streams

回答 1 投票 0

防止Spring WebFlux WebClient在新订阅时执行新的交换

DefaultWebClient的交换实现为：@Override public Mono exchange（）{ClientRequest request =（this.inserter！= null？initRequestBuilder（）....

java spring-webflux project-reactor reactive-streams spring-webclient

回答 1 投票 0

等待ParallelFlux完成

我创建了ParallelFlux，然后使用.sequential（），期望在那时我可以计算或“减少”并行计算的结果。问题似乎是并行线程...

java reactive-programming spring-webflux project-reactor reactor

回答 1 投票 0

如何一一处理单声道列表？

我有一个列表，如List >，Mono >>>，我需要编写一个签名为私有Mono的方法。 buildDto（... ]

java reactive-programming project-reactor

回答 1 投票 0

是否可以发送初始值？

我有一个Web方法，该方法将在时间到时（将其链接到发布/订阅）返回一个通量对象。仅在第一次调用时，至少有可能返回默认值吗？公共通量 ... ...>

spring-webflux project-reactor

回答 2 投票 0

如何在基于Executor的库中使用Project Reactor的Scheduler？

Project Reactor通过定义调度程序，提供了一种很好的方式来定义要在哪个线程池上运行代码。它还为使用CompletableFuture的库提供了桥梁，尽管Mono.fromFuture（...

java apache-kafka amazon-dynamodb project-reactor aws-sdk-java-2.0

回答 1 投票 0

onErrorResume（）不会被调用

我是spring webflux和reactor的新手，当某些特定异常发生时，我希望有一个后备机制，根据我对ErrorResume方法的研究，它可以做到，但不会被调用，所以我...

spring-boot jwt reactive-programming spring-webflux project-reactor

回答 1 投票 0

如何监视Flux.onBackpressureBuffer（）队列大小

在我的反应式应用程序中，我的发布服务器很热，订阅服务器很慢。为了处理需求不足，我使用了onBackpressureBuffer，但是可能的溢出错误有点令人恐惧。如何监视号码...

project-reactor

回答 1 投票 0

在Spring Project Reactor中重启上游发布者时清除流中的运行中元素？

我有一个发布商，可以在MongoDB上执行长时间运行的大型查询，并以Flux返回数据。在数据库中标记为“已处理”的实体将被过滤掉，实体...

spring mongodb spring-boot reactive-programming project-reactor

回答 1 投票 1

Reactor通量与Java光纤之间的差异

我一直在阅读有关Java Fibers的小工作单元，它会映射到Threads。如果发生阻塞调用，则将不同的光纤映射到同一线程。由于Java中的线程是...

java spring-webflux project-reactor reactor-netty fibers

回答 1 投票 1

Projectreactor：并行执行查询并连接结果

晚上好。我正在研究反应式编程，遇到了以下问题。我正在对数据库运行两个并行查询，并希望合并结果并将其返回...

java spring multithreading spring-webflux project-reactor

回答 1 投票 0

[如何使用反应堆Mono更新具有新值的MongoDB文档？（科特琳）

所以上下文是我需要在一个文档中更新一个值，我有一个Mono，参数Object包含诸如用户名（通过唯一的用户名找到正确的用户）和一个...

mongodb kotlin project-reactor

回答 1 投票 0

如何在Spring Flux中停止昂贵的计算

我正在使用Spring react作为服务器来生成昂贵的代，并以Flux的方式逐一返回结果。如果取消请求，则具有停止生成的优点（在cas ...

rx-java spring-webflux project-reactor spring-reactive

回答 1 投票 0

如何从Java SDK或类似的SDK（即rxJava，项目反应器）获取可扩展的I / O绑定异步多线程？

java java-stream rx-java reactive-programming project-reactor

回答 1 投票 0

什么是Reactor中的BehaviorSubject（RxJS）等效项

我精通RxJS，并开始使用Reactor框架（java）。相当于Reactor中的BehaviorSubject？还是在...

project-reactor

回答 1 投票 0

Reactor spring mongodb存储库将多个结果组合在一起

我是反应式编程的新手，目前正在研究基于Spring Webflux的应用程序。我陷入了几个问题。公共类FooServiceImpl {@Autowired私有FooDao fooDao; @ ...

reactive-programming spring-webflux project-reactor reactor reactor-netty

回答 1 投票 0

反应性管道的书写方式

我正在为返回诺言的方法编写方面。请考虑以下方法：public Mono publishToKafka（Stream s）{// publishToKafka是异步返回Mono.just（s）....

java rx-java aop spring-aop project-reactor

回答 1 投票 0

从Mono.first发出第一个成功的结果

我有两个Monos，它们返回404或产生结果。如何将这两个Monos结合起来，一旦Monos成功完成，就会发出结果。 Optional.empty为...

java spring-webflux project-reactor

回答 1 投票 0

Spring响应式：链接存储库结果

Repository repo存储库otherRepo foreach实体：repo.FindAll（）{entityFind = otherRepo.FindById（entity.Prop）if（entityFind！= null）{return entityFind}}我如何...

spring project-reactor reactive

回答 1 投票 0

project-reactor 相关问题

最新问题