project-reactor 相关问题

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

Project Reactor：可能误导性的错误处理文档

我正在阅读有关错误处理的Reactor参考文档，似乎有些错误。例如关于回退方法的这一部分：Flux.just（“key1”，“key2”）。flatMap（k - > ...

spring project-reactor

回答 1 投票 0

Reactor 3.x - 限制groupBy Flux的时间

是否有任何方法可以强制groupBy（）生成的Flux在一段时间后完成（或类似地，限制“开放”组的最大数量），而不管上游的完整性如何？我有 ...

project-reactor

回答 1 投票 4

不明白如何在kotlin中使用flux订阅

我是反应式编程的新手。我希望看到测试提供程序在日志中启动Beat 1000 Beat 2000但是只有测试提供程序启动，没有Beat或完整消息。看起来我想念......

spring kotlin reactive-programming project-reactor

回答 2 投票 0

Spring Integration 5.0 Reactor类型支持

从发行说明（https://spring.io/blog/2017/11/29/spring-integration-5-0-ga-available）：Reactive Streams支持通过FluxMessageChannel，ReactiveStreamsConsumer和直接组织....

java spring spring-integration project-reactor

回答 1 投票 2

使用Project Reactor对反应流进行递归

我的目标是遍历目录图并使用反应流和Project Reactor记录所有名称。由于文件系统是远程的，因此对它的调用是阻塞的。所以我想......

java asynchronous graph parallel-processing project-reactor

回答 1 投票 5

回收累积的bytebuffer Publisher

我们正在迁移到Spring WebFlux（使用reactor-netty）。应用程序使用带有Spring控制器的HTTP协议目前我们有一个过渡解决方案，它将入站IO缓冲区累积到...

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

回答 1 投票 0

Java Reactor：如何从stdin生成Flux？

我想异步读取用户从stdin生成的消息。类似于：Flux.from（stdinPublisher（））.subscribe（msg - > System.out.println（“Received：”+ msg））;那怎么......

java project-reactor spring-webflux

回答 1 投票 3

java reactor filterAndMap？

我想使用reactor实现：for（val worker：getWorkers（request））{val response = worker.tryDo（work）; if（response！= null）{return response;返回null; getWorkers ......

java project-reactor

回答 2 投票 1

是否有相当于Project Reactor的Flux.create（），它适合rxjava-2中的推/拉模型？

Project Reactor具有此工厂方法，用于创建推/拉生产器。 http://projectreactor.io/docs/core/release/reference/#_hybrid_push_pull_model RxJava-2中有没有这样的东西？ ...

rx-java2 project-reactor

回答 2 投票 0

Spring Boot Webflux / Netty - 检测关闭连接

我一直在使用webflux启动程序（spring-boot-starter-webflux）使用spring-boot 2.0.0.RC1。我创建了一个简单的控制器，返回无限的通量。我想那个发布者只...

spring spring-boot project-reactor spring-webflux reactive-streams

回答 2 投票 6

如何对Reactor Flux流中的值求和？

假设我有一个带有findAll（）方法的存储库，它返回一个Iterable of State，其中State是一个表示具有两个字段（带有getter / setter）的US状态的类：name和population。 ...

java reactive-programming project-reactor

回答 2 投票 4

使用webflux处理异常并返回正确的HTTP代码

我正在使用WebFlux的功能端点。我使用onErrorResume：public Mono将服务层发送的异常转换为HTTP错误代码 serviceReturningMonoError（）{...

spring spring-boot project-reactor spring-webflux

回答 2 投票 5

可观察到磁通转换

我在Rxjava中有我的代码，我想改变它的reactor项目。我的rxjava代码是public Observable> getObject（List ids，列表过滤器）{...

project-reactor

回答 1 投票 2

我可以为subscribeOn方法和异步任务使用相同的执行程序

嗨，我有一个简单的问题，假设我有一个类如下：import lombok.Value; import java.nio.file.Path; @Value类ImageResizeRequest {private DownloadedImage downloadedImage; ...

java multithreading java.util.concurrent spring-webflux project-reactor

回答 2 投票 0

如何限制活动的Spring WebClient调用的数量

我有一个要求，我使用Spring Batch从SQL DB中读取一堆行（数千），并在将其写入Kafka主题之前调用REST服务来丰富内容。使用Spring时......

java webclient project-reactor reactor

回答 1 投票 3

Reactive Spring在REST端点测试中不支持ServerHttpRequest作为参数？

问题与这一问题非常相似。除了我使用的事实：org.springframework.http.server.ServerHttpRequest不是HttpServletRequest。测试代码中有例外。真正的通话有效。 ...

java spring spring-webflux project-reactor

回答 1 投票 1

如何在Spring WebFlux中记录请求和响应主体

我希望使用Kotlin在Spring WebFlux上的REST API中集中记录请求和响应。到目前为止，我已尝试过这种方法@Bean fun apiRouter（）= router {（accept（MediaType ....）

spring-boot kotlin project-reactor spring-webflux

回答 6 投票 15

project-reactor 相关问题

最新问题