发生错误时如何将 Mono 转换为 Mono<Void>

Question

我正在尝试编写一个方法来做这样的事情

   Mono<A> ma = networkCall(); //this might fail
   Mono<Void> mv  = ma.map( a -> ....)  #some logic to perform with `A`

   return mv;

诀窍是，ma 很可能会失败，然后我只想记录情况并返回一个 Mono<Void>，它完成时没有错误。

查看Mono api，我刚刚找到onErrorResume 或onErrorReturn，但两者都会采用返回A（我无法制造）的函数，而我想返回@987654328 @。 我想解决方案很简单，但找不到合适的操作。 那么，如果出现错误，我应该对ma 进行哪些操作才能将其转换为Mono<Void>？

Answer 1

我刚刚找到 onErrorResume 或 onErrorReturn 但两者都会采用返回 A 的函数

onErrorReturn()确实要求你返回一个A，但onErrorResume()只要求你返回一个Mono<A>，它可以是空的。

所以你可以使用：

• 如果调用成功，doOnNext() 使用A 执行您的逻辑；
• doOnError() 在调用不成功时记录您的错误；
• onErrorResume() 返回一个空结果
• then() 将结果转换为Mono<Void>。

类似：

networkCall()
        .doOnNext(a -> doSomethingWith(a))
        .doOnError(e -> e.printStackTrace())
        .onErrorResume(e -> Mono.empty())
        .then();