project-reactor 相关问题

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

如何相互并行处理Flux事件？

我有需要进行丰富的传入事件流，然后在它们到达时并行处理。我当时认为Project Reactor是为了这份工作而订购的，但在我的测试中所有的...

project-reactor

回答 1 投票 1

在反应堆3中将通量分成多个通量的最有效方法

在Reactor 3中，通过模式匹配将异质通量分成多个通量的最有效方法是什么？（并且每个通量的后续操作可能会有很大差异）例如，Source ...

reactive-programming project-reactor

回答 1 投票 1

Spring Reactor：如何压缩两个Flux，但有订单？

假设我有两个外部服务。假设我们有一个项目Foo，serviceA返回项目A，而serviceB返回项目B.我想得到的是一个形式的处理程序（A a，B b），其中a和b ...

java reactive-programming project-reactor

回答 1 投票 1

将串通量分成多个通量

我有一个字符串的通量，如field1 = value1，terminalField = true，field2 = value2，field3 = value3，terminalField = true我想根据特定的分隔符拆分成较小的字符串为...

java project-reactor

回答 1 投票 0

在另一个请求中使用DB Request中的Result Mono的值

我希望通过用户名获取用户，将此用户指定为笔记的作者，然后将该笔记保存到数据库中。问题是我得到一个用户的Mono，我无法将其分配给...

spring spring-data spring-webflux project-reactor spring-mongodb

回答 1 投票 0

使用Spring WebFlux中的webclient在Mono上进行条件重复或重试

我想要做的是使用webclient对Webflux中的Mono进行条件重复。情况如下：我们有一些业务休息服务服务返回生成的文档。 ......

java spring webclient spring-webflux project-reactor

回答 1 投票 0

如何从包含在Mono中的对象内的地图中提取条目？

反应堆和弹簧webflux的新手，很难找到范式转换。我有一个单声道它有一张地图的getAttributes（）;我想检查......的内容

project-reactor

回答 1 投票 0

什么相当于弹簧反应堆中的rxjs管道方法？

在Rx 5.5中，有一种管道方法允许将自定义运算符应用于流。弹簧反应器有没有相应的？

spring project-reactor

回答 2 投票 0

Flux未在Spring 5反应堆中订购

我可能错过了一些东西，但我无法弄清楚它是什么。以下代码什么都不做：webClient.get（）。uri（“/ some / path / here”）。retrieve（）.bodyToMono（GetLocationsResponse ....

java reactive-programming project-reactor

回答 1 投票 3

如何创建被动“中间用户”？如何结合所有Flux 零件和加工结果进一步链（转换为Mono ）？

我正在使用spring webflux + mongodb-reactive将二进制文件（图像）保存到Mongo DB。不幸的是spring-boot-starter-data-mongodb-reactive：2.0.5.RELEASE不支持反应...

java spring-webflux project-reactor reactor

回答 1 投票 1

获取Mono的结果，以便将其传递给JpaRepository或其他非反应类

我想知道从Mono（或Flux）获取对象以传递给非反应性方法（如JpaRepository）的适当方法是什么。这是我做的方式：@Service public class ...

spring spring-data-jpa project-reactor

回答 1 投票 1

如何在Flux上调用subscribe和blockLast？

我一直在试验Project Reactor和反应流。使用subscribeOn使流在不同的线程上运行时遇到了一个问题。将我的代码放在主要内容中，我需要......

java project-reactor reactive-streams

回答 1 投票 0

如何回退项目反应堆通量的错误元素onErrorReturn？

可以说我有一个元素抛出错误的通量。 Flux.just（“aeiou”，“aeio”）。map（x - > {if（！x.endsWith（“u”））{throws Exception;} return x;}）。onErrorReturn（/ * This ...

project-reactor reactive

回答 1 投票 0

为什么Flux iterable在Spring Boot Controller中不能用于mongodb的数据？

我有一个弹簧反应式webapp使用响应mongo驱动程序在一个典型的应用程序中的mongodb。下面是控制器中的代码：Flux foos = fooService.findAllFoos（）;助焊剂 ...

spring mongodb project-reactor

回答 2 投票 0

Webflux Mono - 继续运行完成

我有一个功能，可以做一堆东西，最终返回一个Mono。如果我有这样的处理程序：fun handleSomething（request：ServerRequest）：Mono {返回...

java spring kotlin spring-webflux project-reactor

回答 1 投票 1

如何使expectComplete（）事件失败并抛出错误？

以下是我的单元测试代码。我想测试生成无限事件并且不应该期望事件完成的条件。我试图使expectComplete（）失败。 @Test ......

project-reactor

回答 1 投票 -1

如何使用Reactor（Spring WebClient）进行重复调用？

我使用Reactor（Spring5 WebClient）作为我的反应式编程API。我有2个REST端点可以调用。第一个的结果将是第二个的参数。对于第二个API，它将......

spring spring-webflux project-reactor

回答 2 投票 1

Vert.x RxJava和Reactive Streams API

我是Vert.x的新手，目前正在探索它。我发现在vert.x 3中有三种使用方法1）使用普通顶点API 2）使用基于RxJava的API 3）使用基于Reactive Streams的API我想...

rx-java vert.x project-reactor reactive-streams

回答 1 投票 0

模拟服务器的间隔通量？

我尝试为服务编写测试函数，该服务使用来自另一个服务的间隔Flux，创建类似于Flux.interval（Duration.ofSeconds（1））。map（...）。如果看到支持......

okhttp spring-webflux project-reactor mockwebserver

回答 1 投票 0

在Spring Webflux功能应用程序中验证请求的最佳方法是什么

在传统的Web应用程序中，很容易在控制器方法中验证请求主体，例如。 ResponseEntity create（@Valid @ResponseBody Post post）{}如果是MVC应用程序，我们可以......

spring functional-programming bean-validation project-reactor spring-webflux

回答 2 投票 4

project-reactor 相关问题

最新问题