使用 Mono 值并使用它来调用另一个 Mono

Question

我的代码是这样构造的 -

Mono<Address> m1 = method1() // this call returns address
Mono<Boolean> m2 = method2() // this call uses ReactiveMongoTemplate and updates document in Mongo

我正在努力实现这一目标：

当 method1() 返回地址时，我需要使用它并调用 method2() 来更新 MongoDB 文档中的地址。也没有抛出异常。但是我在 method2() 中没有看到任何日志

代码：

Mono<Object> m1 = method1().map(address -> method2(address));

虽然调用了 method2()，但 MongoDB 中的文档更新并未发生。

Answer 1

您的代码 sn-p 返回 Mono<Mono<Boolean>>，因此没有订阅内部 Mono。

你可能应该像这样use the Mono.flatMap operator：

Mono<Boolean> m1 = method1().flatMap(address -> method2(address));

这个操作符将使操作链变平。