Spring Webflux中无法返回Mono<Boolean>的问题排查

你的代码编译错误主要出在这几个点：

• 不该用Mono.just()包裹customRefFlux.collectList().flatMap(...)，因为collectList()本身就返回Mono<List<CustomReference>>，再套Mono.just()会让返回类型变成Mono<Mono<Boolean>>，和方法声明的Mono<Boolean>不匹配。
• flatMap用错了场景：这里只是把List转换成Boolean的同步操作，不需要用flatMap（flatMap用于返回新的异步序列），应该用map。
• lambda表达式里没有明确返回anyMatch的结果（虽然单语句lambda可省略return，但结合前面的错误，先修正核心逻辑）。

修复方案一：修正原逻辑 #

去掉多余的Mono.just()，把flatMap换成map，确保lambda返回判断结果：

public Mono<Boolean> isMandatory(String country, String compliance,String referenceType) {
    Flux<CustomReference> customRefFlux = getCustomsReferenceRule();
    return customRefFlux.collectList()
        .map(customRefList -> 
            customRefList.stream().anyMatch(customRef -> 
                customRef.getType().equalsIgnoreCase(referenceType)
            )
        );
}

修复方案二：更高效的流式写法 #

不需要先把Flux转成List，直接用Flux自带的any()操作符一步判断，避免不必要的集合转换，性能更优：

public Mono<Boolean> isMandatory(String country, String compliance,String referenceType) {
    Flux<CustomReference> customRefFlux = getCustomsReferenceRule();
    return customRefFlux.any(customRef -> 
        customRef.getType().equalsIgnoreCase(referenceType)
    );
}

两种方案都能正确返回Mono<Boolean>，方案二更贴合Reactor的流式编程思想。

内容的提问来源于stack exchange，提问作者Mira Devi