如何让 Mono Void 在另一个 Mono Void 中返回？答案

【问题标题】：How can I make Mono Void get returned in another Mono Void?如何让 Mono Void 在另一个 Mono Void 中返回？
【发布时间】：2021-02-15 11:13:02
【问题描述】：

Mono<Void> my_function(final String reviewObject){  
  return Mono.fromCallable(
            () -> {
              ReviewDto reviewDto = new ReviewDto();
              
              try {
                objectMapper.updateValue(reviewDto, reviewObject);
              } catch (JsonMappingException e) {
                      throw new InvalidPayloadException("Invalid payload");
              }
              return reviewDto;
            }).then();
}

当我调用 my_function 时，它没有调用（工作），我该怎么办？？

Mono<Void> another_function(){
   my_function(reviewObject);
}

【问题讨论】：

nothing happens until you subscribe projectreactor.io/docs/core/release/reference/…
根据@Toerktumlare，您应该在 another_function 方法中调用您的方法，因此：my_function(reviewObject).suscribe();

标签： java rabbitmq spring-webflux project-reactor reactor

【解决方案1】：

Mono<Void> another_function(){
   return my_function(reviewObject);
}

让another_function() 的消费者决定如何处理返回的Mono<Void>！

确切地说，它当然是subscribe() 的这种或其他方式来响应Publisher：https://projectreactor.io/docs/core/release/reference/#_subscribe_method_examples

【讨论】：