如何调用返回Mono<Boolean>的验证方法后返回Flux对象

我有一个返回Mono<Boolean>的validate验证方法，当id1或id2无效时会抛出BadRequestException，验证逻辑本身正常。但当前调用该方法的validateAndGetFacilityResponse方法中，执行validate后直接走到下一行返回facilityService.getFacilityResponse的结果，未正确拦截验证逻辑。

现需以响应式方式重写validateAndGetFacilityResponse方法，使其返回Flux<FacilitiesResponse>。我曾尝试如下代码：

return validate(id1,id2)
       .filter(valid -> valid)
       .map(valid -> facilityService.getFacilityResponse(id1,id2)) 

但该代码返回的是Mono<Flux<FacilitiesResponse>>，且无法修改facilityService.getFacilityResponse的返回类型，请求解决方案。

附相关代码：
验证方法：

public static Mono<Boolean> validate(String id1, String id2) {
   //校验id1和id2的逻辑
   //返回Mono.just(false)/Mono.just(true)
   //或抛出Mono.error(new BadRequestException(""));
}

原调用方法：

public Flux<FacilitiesResponse> validateAndGetFacilityResponse(String id1, String id2) {
    validate(id1,id2);
    return facilityService.getFacilityResponse(id1,id2);  
 }

核心问题是你用了map来处理返回Flux的方法，导致嵌套了Mono<Flux<...>>，改用flatMapMany就能将内部的Flux平铺为顶层流，匹配方法返回类型。同时要处理验证不通过的空信号场景：

完整实现代码 #

public Flux<FacilitiesResponse> validateAndGetFacilityResponse(String id1, String id2) {
    return validate(id1, id2)
            // 过滤掉验证不通过的信号
            .filter(valid -> valid)
            // 用flatMapMany将Mono转换为目标Flux类型
            .flatMapMany(valid -> facilityService.getFacilityResponse(id1, id2))
            // 处理验证不通过导致的空流，转为抛出异常
            .switchIfEmpty(Mono.error(new BadRequestException("ID验证不通过")));
}

关键细节说明 #

1. flatMapMany的作用：它专门用于从Mono中生成Flux，能直接将facilityService返回的Flux平铺到顶层，最终整个链式调用的返回类型就是Flux<FacilitiesResponse>，完全符合方法要求。
2. switchIfEmpty的必要性：如果validate返回Mono.just(false)，filter会过滤掉这个信号，流会变成空。通过switchIfEmpty可以把空信号转为BadRequestException，保证验证不通过时能正确抛出异常。
3. 简化场景：如果你的validate方法已经在验证失败时直接抛出Mono.error（而非返回false），可以去掉filter和switchIfEmpty，代码更简洁：

public Flux<FacilitiesResponse> validateAndGetFacilityResponse(String id1, String id2) {
    return validate(id1, id2)
            .flatMapMany(valid -> facilityService.getFacilityResponse(id1, id2));
}

内容的提问来源于stack exchange，提问作者Rahul Raj