如何将 List<Mono<String>> 组合成一个大字符串？

Question

我创建了一个字符串单声道列表List<Mono<String>> myList。现在我需要将它们连接成一个大字符串。

当我初始化 StringBuilder 并异步更新它时，可能会返回空行。

//method body....

StringBuilder builder = new StringBuilder();

myList.forEach {
    mono ->
    mono.map{ str -> builder.append(str)}
}

return builder.toString() //<- is ""

如何让构建器等待单声道？

Answer 1

最好的方法是将 Monos List 转换为 Flux，然后将 Flux 减少到一个包含所有子字符串的字符串。然后你就有了 Mono ，你仍然可以以异步方式使用它。 （如果您想与项目反应器保持异步范式，则应始终使用 Mono/Flux）

例子：

    List<Mono<String>> listOfMonosWithString = Arrays.asList(Mono.just("a"), Mono.just("b"), Mono.just("c"));
    Flux<String> mergedMonos = Flux.fromIterable(listOfMonosWithString)
            .flatMapSequential(Function.identity());

    mergedMonos
            .reduce(String::concat)
            .doOnNext(System.out::println)
            .subscribe();