RxJava 通过 id 比较来自两个 observable 的不同项目

Question

我有两个 Observables (O1 & O2) 发出不同类型的项目。如果A.Id 包含在O1 中，我想从O2 中忽略A*.sameId。到目前为止，我想出的最佳解决方案是首先将 O1 中的所有 Id 加载到 Set 中（等待 onComplete() or blocking ）。然后我从O2 加载元素并将它们与O2 Set 和filter() 进行一一比较。

仅使用运算符来表达这一点的最佳（最优雅）方式是什么？

Answer 1

是的，您需要 O1 的完整集合来检查 O2 的值：

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