如何将 Mono<Map<String, Optional<String>>> 转换为 Flux<Tuple<String, Optional<String>>>答案

【问题标题】：How to convert a Mono<Map<String, Optional<String>>> to a Flux<Tuple<String, Optional<String>>>如何将 Mono<Map<String, Optional<String>>> 转换为 Flux<Tuple<String, Optional<String>>>
【发布时间】：2021-03-04 19:31:53
【问题描述】：

我将 WebFlux 与 Reactor 一起使用，并创建了一个休息服务，该服务使用 WebFlux webclient 聚合和转换内部服务调用的结果。

客户端返回一个Mono<Map<String, Optional<String>>> 我想用键、值元素在 Flux 中反汇编，以便稍后将其组合起来。

我正在考虑转换类型的客户端响应

Mono<Map<String, Optional<String>>> 给一个

Flux<Tuple<String, String>>

我知道您可以使用 responseMono.flatMapMany(Flux::fromIterable) 将 Mono<List<String>> 转换为 Flux<String>

但我找不到处理地图的方法。

【问题讨论】：

标签： spring-webflux project-reactor

【解决方案1】：

您可以使用mono.flatMapMany(map -> Flux.fromIterable(map.entrySet()))，它会给您一个Flux<Entry<String, Optional<String>>>。

如果您明确希望它是 Tuple，而不是 Entry，那么就这样做：

mono.flatMapMany(map -> Flux.fromIterable(map.entrySet()))
        .map(e -> Tuples.of(e.getKey(), e.getValue()));

【讨论】：