spring-webflux - Flux.concatMap 在返回结果之前进入下一个事件

Question

我有一个 Flux 测试用例对象，对于每个对象，我需要调用一个外部服务，一旦收到服务响应，在接下来的操作中，它会检查响应是否有效。但是对于一些随机的对象，在收到来自外部服务的响应之前，Flux 正在释放信号。

Flux.fromIterable(masterTestCasesList).concatMap(tc -> iSandBoxRuleEngineClient.getRoutePlanResponseForTestCase(tc))
        .map(respObj -> {//checks if the response is matched.
            return result;}).collectList();
                                    
                                    

预期结果：1）Ref Id：10002 TestCase：TESTCASE_1。2) 在调用 Ref Id: 10002 TestCase : TESTCASE_1 的服务之前。3）命中后：Resp生成；参考 ID：10002 测试用例：TESTCASE_1。4)Ref Id: 10002 TestCase : TESTCASE_1 匹配为真。

1）参考 ID：10002 测试用例：TESTCASE_2。2) 在为 Ref Id: 10002 TestCase : TESTCASE_2 调用服务之前。3）命中后：Resp生成；参考 ID：10002 测试用例：TESTCASE_2。4)Ref Id: 10002 TestCase : TESTCASE_2 匹配为真。

1）参考 ID：10002 测试用例：TESTCASE_3。2) 在为 Ref Id: 10002 TestCase : TESTCASE_3 调用服务之前。3）命中后：Resp生成；参考 ID：10002 测试用例：TESTCASE_3。4)Ref Id: 10002 TestCase : TESTCASE_3 匹配为真。

生成的输出：

1）参考 ID：10002 测试用例：TESTCASE_1。2) 在调用 Ref Id: 10002 TestCase : TESTCASE_1 的服务之前。3）命中后：Resp生成；参考 ID：10002 测试用例：TESTCASE_1。4)Ref Id: 10002 TestCase : TESTCASE_1 匹配为真。

1）参考 ID：10002 测试用例：TESTCASE_2。2) 在为 Ref Id: 10002 TestCase : TESTCASE_2 调用服务之前。

1）参考 ID：10002 测试用例：TESTCASE_3。2) 在为 Ref Id: 10002 TestCase : TESTCASE_3 调用服务之前。3）命中后：Resp生成；参考 ID：10002 测试用例：TESTCASE_3。4)Ref Id: 10002 TestCase : TESTCASE_3 匹配为真。