如何在另一个反应流中使用一个反应流作为if语句的结果

Question

我必须将一个返回Enum的方法重构为reactive。价值该方法的工作原理类似于从一个if语句到另一个if语句的过滤器。当一些if语句返回true（on map（）方法）或遍历所有元素的路径时，我使用Pair和code来阻止链。它是有效的，但在map（）if语句中使用了两个辅助方法，它们实际上是阻塞的，所以我必须使它们成为非阻塞的。辅助方法One返回布尔值，每次调用该方法时都必须调用它。下面是示例代码：

java prettyprint-override">
public Mono<Enum> method(String param) {
return Mono.just(param)
   .map(
      //filter if-statement
    )
 .map(
      //filter if-statement
    )
 .map(
    pair -> {
       if (auxiliaryMethodOne(param)) {
      //filter if-statement
        }
      }
    )
 .map(
      //filter if-statement
    )
}

private Mono <Boolean> auxiliaryMethodOne(String param) {
    //some logic returns Mono<Boolean>
}

Answer 1

您可以在以下情况下使用Mono#filter:

myMono.filterWhen(pair -> auxiliaryMethodOne(param))