在Spring Webflux中的Mono <Response <T >>中转换Flux <T>

用户13674325:

我们正在使用Spring Data响应式,当我们调用时findAll我们收到,Flux<T>并且我们希望在API中公开此响应,但是我们的API结构是

{
    "status": 200,
    "items": [ ... ]
}

因此,我们希望将其公开为 Mono<<Response<T>>

public class Response<T> {
    private int status;
    private List<T> items;
    // ...
}

如何转换Flux<T>Mono<Response<T>>春季Webflux?

布莱恩·克洛泽(Brian Clozel):
Flux<User> users = //...
Mono<Response<User>> response = users.collectList().map(items -> new Response(items));

本文收集自互联网,转载请注明来源。

如有侵权,请联系 [email protected] 删除。

编辑于
0

我来说两句

0 条评论
登录 后参与评论

相关文章

Mono <T>和Flux <T>作为函数中的参数

如何在Spring Webflux中返回Mono <Map <String,Flux <Integer >>>响应?

webflux Mono <T> onErrorReturn不被调用

Spring webflux 中的 void 与 Mono<Void>

在Spring Web Controller中使用Mono <T>

在 mex 中转换 const size_t

怎么把List <Mono <T >>转换成Mono <List <T >>?

Java Reactor:有没有一种方法可以将Flux <Mono <T >>转换为Flux <T>而又不急于获取?

Spring webflux 5.2.3 bodyToMono 在 onStatus 中的空 Mono 之后调用

在 Spring webflux 中抛出异常 vs Mono.error()

如何在Spring WebFlux中整合Mono Objects的结果?

Spring WebFlux - 将 Flux 转换为 List<Object>

如何从Spring Webflux将专有流转换为Flux

是否可以在Kotlin中模拟改造后的Deferred <Response <T >>?

如何通过Spring WebFlux Reactive方法在处理函数中使用Mono和Flux

Spring Webflux和@Cacheable-Mono / Flux类型的结果缓存的正确方法

Spring webflux 与 Mono 对象交互

将Spring Webflux Mono转换为Either,最好没有阻塞?

Spring webflux 将实体类转换为 Mono DTO 对象

Spring WebFlux - 不可转换的类型;无法投射“reactor.core.publisher.Mono”

如何使用 reactor.core.publisher Mono<T> 或 Flux<T> 继承?

从Spring WebFlux Web应用程序中的WebClient调用中缓存Mono的结果

javax.ws.rs.core.Response在Java1.6中转换为字符串

Spring WebFlux-通过WebClient为Mono内列表中的每个元素发送HTTP请求

@RequestBody是否应该在Spring Webflux中与Mono Publisher一起包装?

Spring webflux 反应式 Mono::subscribe

通用类<T>中的Java通用Map <T,T>抛出不兼容的类型:T无法转换为T`错误

如何通过使用Reactor 3.x将List <T>转换为Flux <T>

转换流<流<T >>到T [] [与流/λ的在Java中]