Python
Java
PHP
IOS
Android
Nodejs
JavaScript
Html5
Windows
Ubuntu
Linux
如何返回 Mono
,其中响应实体可以是两种不同类型
我是 Spring Webflux Reactor Core 的新手 正在尝试执行以下功能 调用 userservice LoginWebApp 如果返回用户 则返回类型为 User 的ResponseEntity 如果为空 则返回 Str
functionalprogramming
reactiveprogramming
SpringWebFlux
projectreactor
在项目反应器中包装阻塞 I/O
我有一个 spring webflux API 它在服务层需要从使用 JDBC 的现有存储库中读取 在阅读了有关该主题的一些内容后 我希望将阻塞数据库调用的执行与其余非阻塞异步代码分开 我定义了一个专用的jdbcScheduler Bean
Java
projectreactor
反应式异常处理
如何使用一个Mono error
SpringWebFlux
projectreactor
如何在 r2dbc 中连接表?
在java反应器中 r2dbc 我有两个表 A B 我还为它们定义了存储库 如何获取A连接B组成的数据 我只提出以下方法 从 A 调用databaseClient select 然后在循环中从 B 调用 select 但我想要更有效和反应性
projectreactor
springdatar2dbc
r2dbc
使用 WebFlux 从资源中读取和解析文件的反应方式?
我想知道从资源中读取 解析和提供文件的正确方法是什么 目前 我做了这样的事情 fun getFile request ServerRequest Mono
json
kotlin
SpringWebFlux
projectreactor
如何将 Micrometer 计时器与 webflux 端点一起使用
是否有任何简单的方法可以将 Micrometer 计时器与 Webflux 控制器一起使用 看来 Timed 仅适用于非反应式方法 对于反应性来说 它记录的时间值非常低 我发现了一个类似的问题 如何使用 Micrometer Timer 记
Java
SpringWebFlux
projectreactor
Micrometer
如何迭代 Flux 并与 Mono 混合
我有一个应该向用户发送电子邮件的用例 首先 我创建电子邮件正文 Mono
Java
reactiveprogramming
projectreactor
SpringWebFlux
如何在 Reactor 中使用多线程执行 flatMap?
我尝试过运行flatMap on a Flux range其次是subscribeOn似乎所有操作都在同一个线程上运行 这是正常的吗 Flux range 0 1000000 log flatMap it 1 subscribeOn Sch
Multithreading
kotlin
projectreactor
为反应式管道编写方面
我正在为返回承诺的方法编写方面 考虑以下方法 public Mono
Java
RXJava
AOP
SpringAOP
projectreactor
Spring 5 Web Reactive - 热门发布 - 如何使用 EmitterProcessor 将 MessageListener 桥接到事件流
示例项目位于此处 https github com codependent spring5 playground https github com codependent spring5 playground 我想将从 JMS 队列接收到的
Spring
SpringMVC
reactiveprogramming
projectreactor
SpringWebFlux
如何使用 Reactor 3.x 将 List
转换为 Flux
我有一个异步调用节俭接口 public CompletableFuture
Java
reactiveprogramming
projectreactor
如果满足条件,Reactor如何重复某个步骤n次
请帮我处理反应堆 我需要检查一个条件最多n次并返回最终结果 我发现reactor有reactor extra模块 https projectreactor io docs extra snapshot api reactor retry R
projectreactor
无法构造 `reactor.core.publisher.Mono` Spring Cloud OpenFeign 和 Spring boot 2 的实例
Goal 从 Spring Boot 1 x webMvc 迁移到版本 2 webFlux 从 Spring Cloud Edgware SR2 迁移到 FinchleyM8 等待发布版本 Problem Feign gt OpenFeig
springboot
springCloud
projectreactor
反应流与反应堆模式?
我想知道反应流 由反应宣言定义 和反应器模式 https en wikipedia org wiki Reactor pattern https en wikipedia org wiki Reactor pattern 我读到 Proje
projectreactor
reactivestreams
使用 Reactor 的非阻塞 ReentrantLock
我需要限制同时处理同一资源的客户端数量所以我尝试实现模拟 lock lock try do work finally lock unlock 但以非阻塞方式使用 Reactor 库 我有这样的东西 但我有一个问题 有一个更好的方法吗或者也许
Java
projectreactor
如何避免 .flatMap(x->reactiveAction(x).thenReturn(x))
在使用项目反应器库进行 Java 反应式编程期间 我偶然发现了一种模式 我想知道是否有开箱即用的支持 所以我想要下面的代码 Mono just hello flatMap hello gt reactiveAction hello then
Java
MONO
reactiveprogramming
projectreactor
Publisher
更新 Reactor 中对象的状态
给出以下方法 private Mono
Java
reactiveprogramming
SpringWebFlux
projectreactor
Reactor 项目和 Java 内存模型
我试图了解 Projectreactor 为应用程序代码提供的数据可见性方面的保证 例如我预计下面的代码会失败 但经过一百万次迭代后它不会失败 我正在更改线程 A 上典型 POJO 的状态 并从线程 B 读回它 Reactor 是否保证 P
Java
reactiveprogramming
projectreactor
Mono/Flux.fromCallable 和 Mono.defer 之间的区别
我通常需要生成一个 Mono Flux 其值将在订阅时生成 计算 对于这一点 fromCallable 和 defer 运算符似乎都很好 我无法在 javadoc 中清楚地看到差异 来自可调用 public static Mono from
SpringWebFlux
projectreactor
Spring Flux 和 Async 注解
我有一个 Spring Flux 应用程序 在某些时候我需要在后台执行一些繁重的任务 调用者 HTTP 请求 不需要等到该任务完成 如果没有反应堆 我可能会使用Async https docs spring io spring framew
Java
Spring
SpringWebFlux
projectreactor
springasync
«
1
2
3
4
5
»