兵变：从单个uni超时恢复

Question

从一个夸克斯（kotlin）应用程序中，我并行请求多个endpoint（相同的endpoint，但有不同的基本网址），然后我合并uni，以便不依次等待每个响应。

以下是一个示例：

      val unis = repository.findUnis()
        ?.sites
        ?.map { site ->
                RestClientBuilder.newBuilder()
                    .baseUri(URI.create(site.url))
                    .build(MyClientService::class.java)
                    .api("param")
                    .ifNoItem()
                        .after(Duration.ofMillis(1))
                        .recoverWithItem(null)
                    .onFailure()
                        .invoke {
                        logger.info("Error while connecting to ${site.url}", it)
                    }
                        .onFailure()
                        .recoverWithItem(null as? String)
        }

    return Uni.combine().all().unis<String>(unis)
            .combinedWith { it as (List<String?>?) }
            .await().atMost(Duration.ofMillis(1))
            ?.filterNotNull()

我遇到的问题是，在超时的情况下不使用ifNoItem。如果单个uni需要超过1毫秒（此值仅用于测试...），则最后一个块将在cominedwith（...）. wait（）处抛出TimeoutExc0019。

我想在单个uni级别处理超时，并且将此错误视为失败（并记录和恢复）。但这似乎行不通。我的实现来自https://smallrye.io/smallrye-mutiny/#_how_do_i_handle_timeout）。

如何做好这件事？

Answer 1

而不是。ifNoItem（）。在（百万分之一的持续时间）之后。recoverWithItem（null），使用：。ifNoItem（）。之后（持续时间）。百万（1）。fail（），它将传播故障。