用自己的郵編無效流量

Question

我正在使用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階段跳過失敗的迭代？

Answer 1

我終於選擇了使用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()，刪除元組丟失可選項