我想根据某种条件将一种焊剂的含量填充到另一种焊剂中。这是我的两个通量:
Flux<templateVersionBo> templateVerion = templateVersionRepo.findAll();
Flux<templateBo> template = templateRepo.findAll();
templateVersion包含模板的ID。我想将模板版本填充到模板变量中,例如template'publishedVersion',并返回templateBo流量,如下所示:
if (templateVersion.getTemplateId().equals(template.getId()) {
templateBo.setTemplatePublishedVersion(version);
}
return templateBo;
我是反应式编程的新手。因此,即使不使用阻止/订阅也无法确定。
最佳答案
如果您的id
是Long
并且TemplateBo
的版本为“ wither”,则可以映射模板,例如:
// async collect id -> version map
Mono<Map<Long, TemplateVersionBo>> templateVersionsMapMono =
templateVerion.collectMap(TemplateVersionBo::getTemplateId);
// get version from map by template id
Flux<TemplateBo> templateBoFlux = templateVersionsMapMono
.flatMapMany(templateVersionsMap -> template
.map(templateBo -> templateBo.withTemplatePublishedVersion(
templateVersionsMap.get(templateBo.getId()).getVersion())));
关于java - 是否可以基于某个过滤器将一种焊剂的含量插入另一种焊剂,我们在Stack Overflow上找到一个类似的问题:https://stackoverflow.com/questions/52740343/