如何在 Flux<String> 上执行 flatMap() 时获取索引号

Posted

技术标签:

【中文标题】如何在 Flux<String> 上执行 flatMap() 时获取索引号【英文标题】:How to fetch the index number while doing a flatMap() on a Flux<String> 【发布时间】:2021-04-18 10:04:43 【问题描述】:

我有如下代码块

var x = Flux.just("A", "B", "C", "D");
        x.flatMap(y -> 
            System.out.println(y);
            return Mono.just(y);
        ).subscribe();

这成功打印:

A
B
C
D

除了字符串值之外,还有什么方法可以打印索引/记录号?

A - 1
B - 2
C - 3
D - 4

【问题讨论】:

【参考方案1】:

你可以试试index():

x.index()
 .flatMap(y -> 
     System.out.println(y.getT2() + "-" + y.getT1());
     return Mono.just(y);
 )
 .subscribe();

【讨论】:

以上是关于如何在 Flux<String> 上执行 flatMap() 时获取索引号的主要内容,如果未能解决你的问题,请参考以下文章

如何将 Flux<pojo> 转换为 ArrayList<String>

如何将 Mono<List<String>> 转换为 Flux<String>

如何从 Spring Flux 平面图操作中返回对象

从 Spring WebFlux 返回 Flux<String> 返回一个字符串而不是 JSON 中的字符串数组

如何构建避免嵌套 Flux 块(Flux<Flux <T>>)的反应式架构?

如何在文件行出现并将它们表示为 Flux 时读取它们?