返回 Mono<Void> 后的方法调用

Question

我想在先前返回时调用该方法 Mono<Void> ：

  @Override
 public Mono<Void> sendEmail(EmailDto emailDto) {
 return mailReactiveClient.sendEmail(message ->
     createMessage(emailDto, emailDto.getBody(), message))
       .doOnNext(saveNotificationLog(emailDto)); //it's not work
}

  private void saveNotificationLog(EmailDto emailDto) {
    notificationLogReactiveRepository.save(NotificationLog.builder()
       ...
      .build());
  }

方法 sendEmail 返回 Mono<Void> 。

那么如何调用 saveNotificationLog 呢？

UPD： 试图让我的问题更简单：

  @Override
 public Mono<Void> sendEmail(EmailDto emailDto) {
 return mailReactiveClient.sendEmail(message ->
     createMessage(emailDto, emailDto.getBody(), message))
       .doOnNext(System.out.print("Hello world!");
}

如何在 sendEmail 返回 Mono<Void> 之后调用 doOnNext 或类似方法？

原文由 kostepanych 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 1

doOnNext ，一般来说所有 doOn* 反应器方法都是副作用方法。您不应该调用它们来执行 I/O 工作或链操作，而是记录事情而不做任何会影响应用程序状态的事情。

在您的代码示例中， notificationLogReactiveRepository.save 返回 Mono<Void> 。 saveNotificationLog 返回 void 并且不订阅 notificationLogReactiveRepository.save 返回的发布者。这意味着通知不会被保存，因为 在您订阅之前什么都不会发生。

在这种情况下，您似乎正在尝试链接操作 - then 运营商就是为此而生的。您的代码应如下所示：

 @Override
public Mono<Void> sendEmail(EmailDto emailDto) {
    return mailReactiveClient.sendEmail(message ->
        createMessage(emailDto, emailDto.getBody(), message))
           .then(saveNotificationLog(emailDto));
}

private Mono<Void> saveNotificationLog(EmailDto emailDto) {
    return notificationLogReactiveRepository.save(NotificationLog.builder()
        ...
        .build());
}

原文由 Brian Clozel 发布，翻译遵循 CC BY-SA 4.0 许可协议

Answer 2

Mono 不会发出数据，所以 doOnNext 不会被触发。您应该改用 doOnSuccess 。

此外，您的 Mono 需要消耗。没有代码，我们不知道它是不是。

这里有一些例子：我添加了 subscribe() 来消耗单声道。根据您的 Mono 的使用，您将不得不做或不做同样的事情。

这什么都不打印：

 Mono<String> m=Mono.just("test");
Mono<Void> v=m.then();
v.doOnNext(x->System.out.println("OK")).subscribe();

这个打印“OK”：

 Mono<String> m=Mono.just("test");
Mono<Void> v=m.then();
v.doOnSuccess(x->System.out.println("OK")).subscribe();

原文由 wargre 发布，翻译遵循 CC BY-SA 4.0 许可协议