project-reactor 相关问题

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

如何测试服务器发送事件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

为什么Reactor的Mono.fromCompletionStage比普通的CompletableFuture慢？

我有一段简单的代码，在后台 "处理 "数据，每处理完第n个项目后，记录最后n个项目所花费的总时间： class BackgroundWorker implements AutoCloseable { private ...。

java project-reactor completable-future

回答 1 投票 1

如果Mono为空，则创建一个未找到的ServerResponse。

我正在使用Spring Boot 2.2.6、Kotlin和coroutines来实现一个简单的反应式休息API。我正在尝试使用函数式。我如何改变下面的代码来返回404 HTTP ...

spring-boot kotlin spring-webflux project-reactor kotlin-coroutines

回答 1 投票 0

用R2DBC Postgresql WebFlux无法获得响应。

我正在学习R2DBC与spring boot WebFlux和Postgresql。我已经成功地配置了PostgreSQL数据库，它运行在我的本地机器上。我使用了以下的依赖和插件......

postgresql spring-boot spring-webflux project-reactor spring-data-r2dbc

回答 1 投票 0

当ParallelFlux中发生错误时，回滚所有的变化。

我正在使用spring webflux和reactor，我有以下的flux用于上传图片，调整图片大小和存储它们。对于每个尺寸，我在一个自定义的执行器上并行执行所述的通量......。

java spring spring-webflux project-reactor reactor

回答 1 投票 0

onSubscribe([Synchronous Fuseable] FluxArray.ArraySubscription) [ INFO]...

project-reactor

回答 1 投票 0

如何使用spring web flux处理url编码的payload？

客户端发送的是编码的有效载荷(百分比编码)，而给定的代码对于非编码的有效载荷XML(content-type:applicationxml)是有效的，但对于编码的有效载荷XML文件(......)却以http 415失败。

java spring-boot http-headers spring-webflux project-reactor

回答 1 投票 0

用Spring Reactive（R2DBC）连接MSSQL。

我正在尝试与Microsoft SQL Server建立数据库连接。不幸的是，我不能理解为什么它不工作。而错误信息不幸的是，不能给我...

java spring reactive-programming spring-webflux project-reactor

回答 1 投票 1

等待Publisher完成，并将其用于另一个Publisher，该Publisher会将所需数据返回给webflux。

我有一个简单的代码，将一些数据保存在数据库中，并返回保存的值 public Flux----------。保存人员(Flux 人）{单 lastPersonId = ...

java spring-webflux project-reactor

回答 1 投票 -1

Spring Kafka云功能。没有上下文中的事务

我开始涉猎Spring云流和它的云功能支持。我在这里上传了一个示例项目来阐明这个问题->https:/github.comnmarquesantosspring-cloud-function-...

spring-kafka project-reactor spring-cloud-stream spring-cloud-function

回答 1 投票 0

如何在流量中计算项目，如果计数大于X，则返回错误，否则继续使用管道。

我是Spring中Project Reactor的新手，我不完全清楚如何执行一些事情：我有我的管道管道返回记录。一切都很好。但我想计算这些记录，然后做...

java spring reactive-programming project-reactor spring-reactor

回答 1 投票 0

Spring reactive中的MonoProcessor是用来干什么的？

在查看Spring框架的WiretapConnector源代码时，我偶然发现了一个MonoProcessor类型的对象。我试着在谷歌上搜索它的用途解释，但没有用。Javadoc ...

spring project-reactor spring-reactive

回答 1 投票 0

Spring Reactor Webflux Scheduler的并行性

对于完全无阻塞的端到端反应式调用，是否建议显式调用publishOn或 subscribeOn来切换调度器？对于耗费cpu或非耗费cpu的任务，是否有利于...

spring spring-webflux project-reactor reactor-netty spring-reactor

回答 1 投票 1

project-reactor 相关问题

最新问题