RxJava vergleiche verschiedene Artikel nach ID von zwei Observablen

Question

Ich habe zwei Observables (O1 & O2), die Elemente verschiedener Typen ausstrahlen. Wenn A.Id in O1 enthalten ist, möchte ich A*.sameId von O2 ignorieren. Die beste Lösung, die ich bisher gefunden habe, ist das Laden aller IDs von O1 in ein Set zuerst (Warten auf onComplete() or blocking). Dann lade ich die Elemente von O2 und vergleiche sie eins nach eins mit den O2 Set mit filter().

Was ist die beste (eleganteste) Art, dies nur mit Operatoren auszudrücken?

Answer 1

Ja, müssen Sie den vollständigen Satz von O1 Werte von O2 überprüfen:

o1.collect(HashSet::new, (a, b) -> a.add(b)) 
.flatMap(set -> o2.filter(v -> !set.contains(v))) 
...