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

java reactive-programming project-reactor spring-webflux

2022-09-02 05:27:16

我想在上一次返回时调用该方法：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());
  }

方法返回。sendEmailMono<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!"); 
}

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

答案 1

Mono不会发出数据，因此不会被触发。您应该改用。doOnNextdoOnSuccess

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

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

此打印任何内容：

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

答案 2

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

在代码示例中，返回。返回和不订阅由返回的发布者。这意味着不会保存通知，因为在您订阅之前不会发生任何事情。notificationLogReactiveRepository.saveMono<Void>saveNotificationLogvoidnotificationLogReactiveRepository.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());
}