返回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!"); 
}

返回doOnNext后如何调用或类似方法？sendEmailMono<Void>

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());
}

Answer 2

试试这样：

Mono.empty().then() 

Answer 3

单声道不会发射数据，因此doOnNext不会被触发。您应该使用doOnSuccess代替。

另外，您的Mono需要消耗掉。没有代码，我们不知道是否存在。

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

此打印无内容：

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

此打印“确定”：

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