Web客户端返回Mono的Java循环结束条件

我有一个Java Web客户端代码，我将其响应转换为Mono。我希望在API调用上迭代，直到Mono响应匹配特定条件。当然，我不想迭代到无限。我想每隔5秒重复一次，直到30秒。到目前为止我已经试过了

数据-lang="js"数据-隐藏="假"数据-控制台="真"数据-巴贝尔="假">

client.get()
                .uri("https://someUri")
                .retrieve()

                .bodyToMono(Response.class)
                .delayElement(Duration.ofSeconds(5))
                .retryBackoff(5, Duration.ofSeconds(5))
                .delayUntil(r -> {
                    System.out.print("Looping"); 
                    if(condition) {
                        System.out.print(r.getStatus());
                        return Mono.just(r);
                    }
                    return Mono.empty();
                })

但没用。

---

解决方案

您可以使用筛选器，重复WhenEmpty，然后像这样重复

client.get()
    .uri("https://someUri")
    .retrieve()
    .bodyToMono(Response.class)
    .filter(response -> condition)
    .repeatWhenEmpty(Repeat.onlyIf(r -> true)
        .fixedBackoff(Duration.ofSeconds(5))
        .timeout(Duration.ofSeconds(30)))

Repeat类是反应器额外库的一部分

<dependency>
    <groupId>io.projectreactor.addons</groupId>
    <artifactId>reactor-extra</artifactId>
</dependency>