project-reactor 相关问题

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

Webflux：kafka 接收器中 .map() 和 .flatMap() 行为的区别

我已经阅读了 map() 和 flatMap() 方法的项目反应器文档，并且在这个答案中也有很好的解释。但我的问题是关于我们何时使用反应堆 KafkaReceiver。按照...

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

回答 1 投票 0

所以我正在测试一些网关，我有这个更新方法： @覆盖 public Mono update(CustomerInfo 信息){ CustomerEntity customerEntity = new CustomerEntity(); 客户实体。

java unit-testing mockito spring-webflux project-reactor

回答 0 投票 0

在 webclient 的单元测试中填充上下文

我添加了一个 WebClientCustomizer，它从上下文视图中获取一个值，该值将作为传出请求的标头添加。代码如下所示： @覆盖公共无效自定义（WebClient.

spring spring-webflux project-reactor

回答 0 投票 0

如何在 Mono.flatMap 中等待返回单值函数？

Mono studentMono = some1(); Mono schoolMono = some2(); Mono categoryBestPageResponseMono = Mono.zip(studentMono, schoolMono).flatMap(数据 -> { 螺柱...

spring-webflux reactive-programming project-reactor spring-webclient

回答 2 投票 0

如何在 Spring Boot Webflux 中进行顺序 API 调用和合并结果

我已经有一个反应流来执行以下操作： 1.通过调用另一个 REST API 检索包裹 ID 列表 2.通过调用另一个 RES 检索每个包裹 ID 的跟踪事件列表...

java spring-webflux reactive-programming project-reactor

回答 0 投票 0

通过动态查询在ReactiveMongoRepository上实现分页和排序。

我知道分页有点违背反应式原则，但由于需求，我必须让它以某种方式工作。我使用的是Spring Data 2.1.6，我无法升级，所以ReactiveQuerydslSpecification for ...

reactive-programming spring-data-mongodb project-reactor

回答 1 投票 0

为Object Flux实现Upsert功能

我有一个包含对象的flux请求。任务是创建（如果不存在）或更新（如果存在）这些对象。我已经尝试过实现这个功能，如下所示： requestFlux.flatMap(entry -> { ...

rx-java spring-webflux project-reactor nonblocking

回答 1 投票 0

如何过滤空通量

例如，我有以下代码，它创建了一个包含3个数字1,2,3的Mono列表。我想过滤掉数字1。结果将是一个2个数字2,3的列表。我应该在...

project-reactor reactive reactor

回答 1 投票 0

Reactor Mono发布到多个方法

我有一个问题，就是把一个对象发布到多个方法中。我的代码简化版如下：包 org.example.reactive; import lombok.extern.slf4j.Slf4j; import reactor.core......

java mono rx-java project-reactor spring-reactive

回答 1 投票 0

Spring Cloud Sleuth 如何在 Webflux ouf of the box 中传播 MDC 上下文，以便在不同的线程中记录其内容？

我想知道Spring Cloud Sleuth是如何在线程之间传播MDC上下文，使每个线程的MDC参数都可用。我读过这篇文章https:/simonbasle.github.io201802...。

spring-boot spring-cloud spring-webflux project-reactor spring-cloud-sleuth

回答 1 投票 0

在spring Reactor中使用BaseSubscriber钩子与Subscriber方法有什么好处？

projectreactor.iodocscorereleaser参考文档显示了BaseSubscriber的实现，作为在订阅中使用lambdas的替代方案，然而通过阅读参考文档： ...

spring-webflux project-reactor reactive-streams

回答 1 投票 0

反应式存储库只适用于block()。

我有一个Spring引导应用程序。作为它的一部分，我应该跟踪一个简单的对象ActiveVersion，它有两个字段，类型和版本。我在redis和mongo中都持久化了这个对象。...

kotlin reactive-programming project-reactor

回答 1 投票 0

如何测试服务器发送事件API（用Spring 5 Webflux编写），当需要执行操作以生成新的事件时，如何测试？

我试图用下面教程中解释的方式测试我的SSE API，https:/docs.spring.iospringdocscurrentspring-framework-referencetesting.html#webtestclient-stream。不幸的是，...

java spring project-reactor server-sent-events webtestclient

回答 1 投票 1

依赖型web客户端调用--Spring Reactive。

我试图做两个API调用，第二个API调用是依赖于第一个API响应。下面这段代码给出了第一个web客户端调用的响应，但我没有从...

java spring-boot spring-webflux project-reactor spring-reactive

回答 1 投票 0

春天的WebFlux消费者要下沉

下面是一个简单的spring boot应用程序。@SpringBootApplication @RestController public class ReactiveApplication { static Flux (静态 Flux) fluxString; 静态易失性队列 ...

java multithreading spring-boot spring-webflux project-reactor

回答 1 投票 0

Webflux: 重复次数用尽后的OnErrorResume没有被触发。

我试图使用onErrorResume执行重复耗尽后的代码，但onErrorResume没有被触发。以下是代码示例 Mono.just(request) .filter(this::...)

reactive-programming spring-webflux project-reactor reactor reactive-streams

回答 1 投票 0

像操作者一样模仿 "reduceWhile"。

我有一个流的值，我需要 "合并"，直到它们满足某个条件。我不想使用外部变量作为缓冲区来检查我的条件是否得到满足，但我找不到一种方法来做'...'。

spring spring-webflux project-reactor

回答 1 投票 0

使用Spring Reactor Web套接字，基于JavaScript的WebSocket客户端没有收到任何输出到浏览器控制台。

我正在跟踪一个使用Pivotal的Reactor框架API的Web套接字设置教程。这个例子需要在运行Spring Boot Reactive Microservice后，启动...

javascript spring-boot websocket project-reactor

回答 1 投票 0

Kotlin中Reactor Mono扩展函数的通用性问题

我正试图创建一个DTO接口，它有一个方法来将dto转换回它的原始模型。现在我想为Mono类创建一个扩展函数，以便更好地...

generics kotlin project-reactor

回答 1 投票 0

如何从其他方法动态添加元素到反应堆热通量？

我有一个数据源服务，它需要一个观察者作为参数。 void subscribe(Consumer onEventConsumer); 我想使用flux作为RSocket的响应流。我怎样才能做到这一点？在我看来...

java reactive-programming project-reactor flux rsocket

回答 1 投票 0

project-reactor 相关问题

最新问题