我正在使用反应式弹簧引导框架,我的应用程序中有一个这样的流程(psuedo代码):
Flux<String> keys; // getting flux of keys from some part of code Flux<RedisData> response = getDataFromRedisForKeys(keys); Flux<RedisData> responseTypeA = filterATypeResponseFromRedisDataFlux(response); Flux<RedisData> responseTypeB = filterBTypeResponseFromRedisDataFlux(response); Flux<RedisData> responseTypeC = filterCTypeResponseFromRedisDataFlux(response); Flux<RedisData> responseTypeD = filterDTypeResponseFromRedisDataFlux(response);
现在,我看到来自redis的数据被获取了4次,我想要的是我们以反应方式获取一次,并将其分离出来,而不进行阻塞。