我有同步代码，我想用反应器实现非阻塞。

我想并行调用不同的URI，这些调用可以返回响应、错误或什么都没有。

有3种情况：

• 一个请求返回一个响应，我不等待其他请求完成就返回它。如果其他请求更早地返回了错误，我将删除错误
• 至少有一个请求返回错误，没有其他请求返回响应，我返回错误
• 所有请求都没有返回任何内容（没有响应，没有错误），我什么也没有返回

我已经以同步方式做到了这一点：

    AtomicReference<WebClientResponseException> responseException = new AtomicReference<>();
    
    String responseBody = Flux.fromIterable(uriList)
            .flatMap(url -> repo.sendRequest(uri)) 
            // sendRequest  returns a Mono that either emit a response, an error or nothing
            .onErrorContinue(WebClientResponseException.class, (error, element) -> {
                var webclientError = (WebClientResponseException) error;
                responseException.set(webclientError);
            })
            .blockFirst();
    
    return Pair.of(responseBody, responseException.get());

我想删除阻塞调用并返回Mono

据我所知，我对发生的错误保持一种状态，我不能对Reactor保持一种状态。

如何跟踪发生的错误，但不发出它们，因为我想看看其他请求是否稍后发出结果？

这个版本有效吗？

AtomicReference<WebClientResponseException> responseException = new AtomicReference<>();
    
    return Flux.fromIterable(uriList)
            .flatMap(url -> repo.sendRequest(uri)) 
            // sendRequest  returns a Mono that either emit a response, an error or nothing
            .onErrorContinue(WebClientResponseException.class, (error, element) -> {
                var webclientError = (WebClientResponseException) error;
                responseException.set(webclientError);
            })
            .next()
            .switchIfEmpty(Mono.defer(() -> Mono.error(responseException.get())));

原子参考会像闭包一样被关闭吗？