与 Mono<Void> 一起使用 then 时出现意外行为

Question

当使用 .then(Mono<Void>) 组合许多 Mono<Void>s 时，它们不会按预期顺序运行。

有人可以解释下面的工作代码和非工作代码之间的区别吗？

工作代码

StepVerifier.create(
        repository.incrementCounter(bucket, timeStamp)
                .then(repository.incrementCounter(bucket, timeStamp))
                .then(Mono.just(1).flatMap(t -> repository.resetCounter(bucket, timeStamp)))
                .then(Mono.just(1).flatMap(t -> repository.getCounter(bucket, timeStamp))))
        .expectNext(0L)
        .verifyComplete();

不工作

StepVerifier.create(
        repository.incrementCounter(bucket, timeStamp)
                .then(repository.incrementCounter(bucket, timeStamp))
                .then(repository.resetCounter(bucket, timeStamp))
                .then(repository.getCounter(bucket, timeStamp)))
        .expectNext(0L)
        .verifyComplete();

Answer 1

根据Gitter channel，您的存储库应该返回冷的Monos（又名“懒惰”），但您很可能在返回之前就开始调用了。

您可以使用Mono.defer 使其变冷。