将Spring Webflux Mono转换为Earth，最好不阻塞？

Question

我正在使用静态编程语言和Arrow以及来自spring-webflow的WebClient。我想做的是将Mono实例转换为要么。

通过调用earth创建earth实例。右（…） 当网络客户端的响应成功时，或当响应成功时。左（…） 当WebClient返回错误时。

我要找的是Mono中的一种方法，类似于这两种方法中的任何一种。折叠（…）在这里，我可以映射成功和错误的结果，并返回与Mono不同的类型。类似这样的代码（不起作用的伪代码）：

val either : Either<Throwable, ClientResponse> = 
                   webClient().post().exchange()
                                .fold({ throwable -> Either.left(throwable) },
                                      { response -> Either.right(response)})

一个人应该怎么做？




Answer 1

我不太熟悉Arrow库，也不熟悉它的典型用例，所以我将使用Java片段来说明我的观点。

首先，我想首先指出，这种类型似乎是阻塞的，而不是懒惰的（与Mono不同）。将Mono转换为该类型意味着您将使代码阻塞，并且您不应该这样做，例如，在控制器处理程序的中间，或者您将阻塞整个服务器。

这大致相当于：

Mono<ClientResponse> response = webClient.get().uri("/").exchange();
// blocking; return the response or throws an exception
ClientResponse blockingResponse = response.block();

话虽如此，我认为您应该能够将Mono转换为该类型，方法是在其上调用block（）并在其周围调用try/catch块，或将其首先转换为CompletableFuture，例如：

Mono<ClientResponse> response = webClient.get().uri("/").exchange();
Either<Throwable, ClientResponse> either = response
        .toFuture()
        .handle((resp, t) -> Either.fold(t, resp))
        .get();

也许有更好的方法可以做到这一点（尤其是使用内联函数），但它们首先都应该涉及单声道阻塞。

Answer 2

在单声道上没有折叠方法，但可以使用两种方法来实现相同的效果：map和onErrorResume。应该是这样的：

val either : Either<Throwable, ClientResponse> = 
               webClient().post()
                          .exchange()
                          .map { Either.right(it) }
                          .onErrorResume { Either.left(it).toMono() }