map和subscribe在Mono\flux上的区别？

Question

例如，如果我同时调度一个包含3个异步调用的列表，那么以下面的方式应用map操作会阻塞吗？

 Flux.merge(albums.stream().map(album -> {

        Mono<CoverResponse> responseMono  = clientRequestHandler.makeAsyncCall()

           //2.call and handler for async call
           return responseMono
                   .map(response -> processResponse());

       }).collect(Collectors.toList())).then(Mono.just(monoResponse));

在上面的片段中，每个map操作都要阻塞吗？假设第一个呼叫需要5毫秒才能返回，其他每一个呼叫需要2毫秒才能返回，我们是否要等待3ms+2ms+2m=7ms来执行enitre操作？或者只有3ms，因为一旦第一个调用得到解析，那么2ms的调用就已经解析了。

Answer 1

首先，除非有人订阅，否则什么都不会发生。订阅是链中的最后一件事，它将触发所有事件的开始。

其次，您需要理解在parallell中运行某些东西与非阻塞运行某些东西的区别。

要解析第一个映射，它需要执行rest调用，然后使用响应执行第二个映射。这两个不会并行运行。