SpringBoot（v2.3.1）：Webflux Mono-Zip Monos列表

Question

我想知道如何使用这个签名。拉链

public static <R> Mono<R> zip(final Iterable<? extends Mono<?>> monos, Function<? super Object[], ? extends R> combinator) {
    return onAssembly(new MonoZip<>(false, combinator, monos));
}

我有多个单声道创建从网络客户端请求，我想压缩。像这样分别供应每个单声道：

Mono.zip(m1, m2, m3, (a, b, c) -> {  })

但是如果一个单子的列表

List<Mono> monos = new ArrayList();

Mono.zip(monos, () -> {});

我得到一个错误：List

尝试使用是否合适。zip就是这种方式，如果是这样，我如何才能做到这一点。




Answer 1

我可以看到这里有两件事：

1. 在下面的签名中，第一个参数的类型为Iterable

public static <R> Mono<R> zip(final Iterable<? extends Mono<?>> monos, Function<? super Object[], ? extends R> combinator) {
    return onAssembly(new MonoZip<>(false, combinator, monos));
}

正确使用上述方法如下：

List<Mono<YourObject>> monos = new ArrayList<>();
        Mono.zip(monos, objectArray ->
                Arrays.stream(objectArray)
                        .map(object -> yourMapperFunction(object))
                        .collect(Collectors.toList())
        );