返回Mono

Question

我想在上一次返回Mono时调用该方法

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

方法sendmail返回Mono

那么如何调用saveNotificationLog？

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

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

如何在sendmailreturnMono之后调用doOnNext或类似方法




Answer 1

试着这样做：

Mono.empty().then() 

Answer 2

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

在代码示例中，通知LogReactiveRepository.save返回Mono

在本例中，似乎您正在尝试链接操作-，然后操作符就是为此而设计的。您的代码应该如下所示：

@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 3

Mono不会发出数据，因此不会触发doOnNext。您应该使用doOn成功来代替。

此外，你的单声道需要消费。没有代码，我们不知道它是不是。

这里有一些例子：我添加了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();