微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

Flux.concatMap返回结果前先进入下一个事件

如何解决Flux.concatMap返回结果前先进入下一个事件

我有一个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)在致电参考编号服务之前:10002 TestCase:TESTCASE_1。 3)点击后:生成响应;参考号:10002 TestCase:TESTCASE_1。 4)参考编号:10002 TestCase:TESTCASE_1与true匹配。

1)参考编号:10002 TestCase:TESTCASE_2。 2)在致电参考编号服务之前:10002 TestCase:TESTCASE_2。 3)点击后:生成响应;参考号:10002 TestCase:TESTCASE_2。 4)参考ID:10002 TestCase:TESTCASE_2与true匹配。

1)参考编号:10002 TestCase:TESTCASE_3。 2)在调用引用ID的服务之前:10002 TestCase:TESTCASE_3。 3)点击后:生成响应;参考号:10002 TestCase:TESTCASE_3。 4)参考编号:10002 TestCase:TESTCASE_3与true匹配。

生成输出

1)参考编号:10002 TestCase:TESTCASE_1。 2)在致电参考编号服务之前:10002 TestCase:TESTCASE_1。 3)点击后:生成响应;参考号:10002 TestCase:TESTCASE_1。 4)参考编号:10002 TestCase:TESTCASE_1与true匹配。

1)参考编号:10002 TestCase:TESTCASE_2。 2)在致电参考编号服务之前:10002 TestCase:TESTCASE_2。

1)参考ID:10002 TestCase:TESTCASE_3。 2)在调用引用ID的服务之前:10002 TestCase:TESTCASE_3。 3)点击后:生成响应;参考号:10002 TestCase:TESTCASE_3。 4)参考编号:10002 TestCase:TESTCASE_3与true匹配。

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。