Mono链的Webflow超时

我正在使用Spring Webflow，并尝试理解Monos链的超时概念。

例如，有一系列Mono调用：

myService.firstOperation()
.then(myService.secondOperation())
...
.then(myService.nOperation())
.timeout(3000L)

如何应用超时：

1)一般操作(操作总时间)

2)用于ECH操作(每次操作不应超过超时)

3)仅用于最后一次操作(n操作)

？

我几乎可以肯定，超时适用于最后一个发布者。如果是，如何将超时应用于操作总数？

---

解决方案

超时运算符测量从订阅时间到超时运算符观察到的onNext/onComplete信号之间经过的时间。

考虑以下示例：

Mono.delay(Duration.ofMillis(1000))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .then(Mono.delay(Duration.ofMillis(1000)))
    .timeout(Duration.ofMillis(2500))
    .block();

如果语句2(两次操作之间测量的时间)或3(仅上次操作的持续时间计数)正确，则上面的代码不会引发任何错误。

但是，超时操作测量的是上游所有操作的持续时间，因此语句1(测量的所有操作的总和)是正确的。

在本例中，所有操作的总和(1000+1000+1000=3000ms)大于配置的超时时间(2500ms)，因此代码会导致错误。