Spring Reactor - 等到一个单声道完成然后再做下一个单声道

Question

假设我有一个返回 Mono 的 repository.save(..) 方法。

还可以说我有一个返回 Mono 的 repository.findByEmail(..)。

问题：

我希望第一个 Mono 在完成第二个 Mono 之后完成。

repository.save(..).then(repository.findByEmail(..))

但是，这里的第二个 Mono 总是先执行？ 我的印象是.then(..) finishes and then plays another Mono

源码说：
Let this {@link Mono} complete then play another Mono.

我的问题有什么解决方案？

Answer 1

是什么让您认为该运算符的行为与预期不符？

以下示例显示了它的作用：

Mono.just("first").log()
                .then(Mono.just("second")).log()
                .subscribe();

日志：

[main] INFO  reactor.Mono.IgnoreThen.2 - | onSubscribe([Fuseable] MonoIgnoreThen.ThenIgnoreMain)
[main] INFO  reactor.Mono.IgnoreThen.2 - | request(unbounded)
[main] INFO  reactor.Mono.Just.1 - | onSubscribe([Synchronous Fuseable] Operators.ScalarSubscription)
[main] INFO  reactor.Mono.Just.1 - | request(unbounded)
[main] INFO  reactor.Mono.Just.1 - | onNext(first)
[main] INFO  reactor.Mono.Just.1 - | onComplete()
[main] INFO  reactor.Mono.IgnoreThen.2 - | onNext(second)
[main] INFO  reactor.Mono.IgnoreThen.2 - | onComplete()

请添加log 操作员并分享您问题中的日志。