Reactor是一个基础库，用于构建JVM上的反应式快速数据应用程序。它提供了Java，Groovy和其他JVM语言的抽象，使构建事件和数据驱动的应用程序更容易。它也非常快。
为什么Flux iterable在Spring Boot Controller中不能用于mongodb的数据？
我有一个弹簧反应式webapp使用响应mongo驱动程序在一个典型的应用程序中的mongodb。下面是控制器中的代码：Flux foos = fooService.findAllFoos（）;助焊剂 ...
我有一个功能，可以做一堆东西，最终返回一个Mono。如果我有这样的处理程序：fun handleSomething（request：ServerRequest）：Mono {返回...
以下是我的单元测试代码。我想测试生成无限事件并且不应该期望事件完成的条件。我试图使expectComplete（）失败。 @Test ......
如何使用Reactor（Spring WebClient）进行重复调用？
我使用Reactor（Spring5 WebClient）作为我的反应式编程API。我有2个REST端点可以调用。第一个的结果将是第二个的参数。对于第二个API，它将......
Vert.x RxJava和Reactive Streams API
我是Vert.x的新手，目前正在探索它。我发现在vert.x 3中有三种使用方法1）使用普通顶点API 2）使用基于RxJava的API 3）使用基于Reactive Streams的API我想...
我尝试为服务编写测试函数，该服务使用来自另一个服务的间隔Flux，创建类似于Flux.interval（Duration.ofSeconds（1））。map（...）。如果看到支持......
在Spring Webflux功能应用程序中验证请求的最佳方法是什么
在传统的Web应用程序中，很容易在控制器方法中验证请求主体，例如。 ResponseEntity create（@Valid @ResponseBody Post post）{}如果是MVC应用程序，我们可以......
当我从一些教程中注意到你只能订阅一个发布者时，我正在研究Java Flux API。然而，我看到一个用例，在一个订阅中有多个发布者是......
Project reactor：flatMap之后的onErrorResume
Flux.just（“a”，“b”）。flatMap（s - > s.equals（“a”）？Mono.error（new RuntimeException（）：Flux.just（s +“1”，s +“2） “））。onErrorResume（throwable - > Mono.empty（））.subscribe（...
我知道combineLatest（）将两个到六个Flux实例中的最后一个值组合在一起（在项目中组合发布者）。但是，假设我有一个List > listOfFlux。是吗 ...
Spring 5 + WebFlux Security + JWT令牌
在我们使用Spring Boot 2启动器+ Spring 5.0.7 + Reactor（WebFlux）的项目中，我们希望使用Spring Security实现安全性。只包括入门者： ＆...
考虑代码示例：import org.springframework.beans.factory.annotation.Autowired; import org.springframework.stereotype.Component; import org.springframework.web.reactive.function.client ....
在下面的代码片段中，抛出异常，如预期：@Test public void testError（）{Mono.error（new NullPointerException（））.subscribe（）;但是，在......
我有一个函数将输入作为Mono：public static Mono返回 emitter（int param）{return Mono.just（param）.delayElement（Duration.ofMillis（100））; //延迟到......
我需要处理Flux流错误，为此我需要知道究竟什么项失败。似乎方法doOnError应该适合处理错误，但是我只能获得异常并且......
如何在spring-webflux WebClient中限制打开套接字的数量？
我有一些RESTful服务，我有想法使用Reactor和Spring WebClient准备简单的性能基准测试。 Benchmark只创建N个用户，然后为每个创建的用户发布M个投票。 ...
Reactor 3 - 如何在Mono Error上返回Flux？
这是样板代码：我想做这样的事情 - 公共Flux getSomething（String email）{method1（email）.map（result - > {// method1返回Mono ...
Project Reactor使用slf4j进行非阻塞日志记录
Project Reactor的Flux.class中的log（）方法提到如果slf4j可用，它将被使用。如果您使用loglf实现，例如使用slf4j进行logback，它们默认为阻塞，...
假设我有一个由4个阶段组成的Reactor流：Mono.just（event）.map（this :: map1）.map（this :: map2）.map（this :: map3）.map（this :: map4 ）我想通过...访问这个:: map1的结果
在mono.compose（）和simple mono.doOnSuccess（）中添加doOnSuccess（）有什么好处吗？
看看Spring Actuator MetricsWebFilter并看到了这段代码：@Override public Mono filter（ServerWebExchange exchange，WebFilterChain chain）{return chain.filter（exchange）....