java在另一个通量结束后执行并行通量

Question

顺便说一句，我还在学习weblux； 我不知道这是否可能，或者我的方法是错误的，但考虑到这种平行通量

Flux<String> enablers = Flux.fromIterable(enablersList)
                .parallel()
                .runOn(Schedulers.elastic())
                .flatMap(element -> service.getAMono(string, entity, element))
                .sequential();

谁调用具有webclient请求的方法（service.getAMono）

webClient.post()
              .uri(url)
              .headers(headers -> headers.addAll(httpHeaders))
              .body(BodyInserters.fromObject(request))
              .retrieve()
              .bodyToMono(entity2.class);

我需要等待enablers flux的流结束，并处理其中的所有响应，原因是如果其中一个给我错误或负面响应，我不会为阻止程序运行另一个并行flux

Flux<String> blockers = Flux.fromIterable(blockersList)
                .parallel()
                .runOn(Schedulers.elastic())
                .flatMap(element -> service.callAMono(string, entity, element))
                .sequential();

我对“zip”方法很感兴趣，但这个方法将两种响应合并在一起，这不是我想要的 如果有人能帮我的话

更新

enablers. //handle enablers response and if error return a custom Mono<response> with .reduce

如果enablers的句柄中没有错误，则与另一个Flux一起转到.thenMany