用自己的邮编无效流量

问题描述：

我正在使用Java Reactor核心，并且我有一个被动对象Flux。对于Flux的每个对象，我需要做一个外部查询，为每个输入返回一个不同的对象。然后新生成的Flux需要与原始的一个压缩 - 所以2 Flux的项目必须以相同的顺序同步和生成。用自己的邮编无效流量

我只是相同的流量的两倍，这样重新使用：

Flux<MyObj> aTest = Flux.fromIterable(aListOfObj); 

Flux<String> myObjLists = aTest.map(o -> MyRepository.findById(o.name)).map(o -> { 
    if (!o.isPresent()) { 
    System.out.println("Fallback to empty-object"); 
    return ""; 
    } 
    List<String> l = o.get(); 
    if (l.size() > 1) { 
    System.out.println("that's bad"); 
    } 
    return l.get(0); 
}); 

Flux.zip(aTest, myObjLists, (a, b) -> doSomethingWith(a,b))

是它做的正确方法？如果myObjLists发出错误，那么如何防止zip阶段跳过失败的迭代？

答

我终于选择了使用Tuple S和Optional秒（以防止空的项目，将打破流量），这样我就不需要再使用初始Flux：

Flux<Tuple<MyObj, Optional<String>>> myObjLists = Flux.fromIterable(aListOfObj) 
    .map(o -> Tuples.of(o, Optional.ofNullable(MyRepository.findById(o.name)) 
    .flatMap(t -> { 
    if (!t.getT2().isPresent()) { 
     System.out.println("Discarding this item"); 
     return Flux.empty(); 
    } 
    List<String> l = t.getT2().get(); 
    if (l.size() > 1) { 
     System.out.println("that's bad"); 
    } 
    return Tuples.of(t.getT1(), l.get(0)); 
    }) 
    .map(t -> doSomethingWith(t.getT1(),t.getT2()))

请注意，flatMap可以替换为.map().filter()，删除元组丢失可选项

用自己的邮编无效流量

相关推荐