Spring Boot (v2.3.1)：Webflux Mono Zip 列表 Monos

Question

我正在尝试弄清楚如何使用 .zip 的这个签名

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

我有多个从 web 客户端请求创建的单声道，我想压缩它们。像这样单独提供每个单声道：

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

但是如果一个单声道列表像

List<Mono> monos = new ArrayList();

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

我收到一个错误：List<Mono> is not compatible with Iterable<? extends Mono<?>>

以这种方式尝试使用 .zip 是否合适，如果合适，我该如何实现。

Answer 1

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

1. 在下面的签名中，第一个参数必须是 Iterable<? extends Mono<?>> monos 类型，这意味着您的第一个参数 (monos) 必须是通用类型 Mono>，例如 Mono。
2. 第二个参数必须是对象数组，即Object[]。所以作为 lambda 表达式参数的 (a, b, c) 无效。

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())
        );