单/通量：如何挂起线程并等待事件或超时

Question

谢谢。

Answer 1

最后我找到了解决办法。

也许不是最优雅的，但工作，使用递归

此代码查询变量状态得到肯定的响应，但不超过10秒的超时。

val delayDuration = Duration.ofMillis(200)
val maximumAttempts = 50

fun createDelayedMono(counter : Int) : Mono<BigInteger> {

    val mono = Mono.delay(delayDuration).flatMap {
        it ->

        if (counter < maximumAttempts && reactorHelper.isEventCompleted(rrn)) {
            reactorHelper.removeEvent(rrn)
            return@flatMap Mono.just(BigInteger.ZERO)
        } else {
            return@flatMap createDelayedMono(counter + 1)
        }

    }

    return mono
}