Zipリアクションフロー自体

Question

私はJava Reactor Coreを使用していますが、私はオブジェクトの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フェーズで失敗した繰り返しをスキップできますか？私は最初のFluxを再利用する必要がないように私は最終的に、（フラックスを破るヌル・アイテムを防ぐため）Tuple sおよびOptional秒を使用するために選んだき

Answer 1

：

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()に置き換えられ、欠落しているタプルを削除することができます。