java - RxJava 比较来自两个可观察对象的不同项目 (java 7)

Question

我有两个发出 items 的 Observables ob1 和 ob2。如果 ob1.item 包含在 ob2 中，我想忽略它。

示例:

ob1 contains A,B,C,D

ob2 contains E,C,B,G,J,O

输出:

ob contains A,D

最好的表达方式是什么？

Answer 1

有一个contains返回 Observable<Boolean> 的运算符observable 是否包含给定元素。

Observable<Boolean> contains = observable2.contains(string);

您需要映射observable1 中的所有元素那些 boolean 可观察量

observable1.map(new Func1<String, Observable<Boolean>>() {
    @Override
    public Observable<Boolean> call(final String string) {
        return observable2.contains(string);
    }
})

这会给你 Observable<Observable<Boolean>> ，但是很难处理这个。因此，您将所有这些 boolean 可观察值连接成一个。幸运的是，您需要做的就是使用 concatMap而不是 map

observable1.concatMap(new Func1<String, Observable<Boolean>>() {
    @Override
    public Observable<Boolean> call(final String string) {
        return observable2.contains(string);
    }
})

现在你有一个 observable1包含您的元素和一个 Observable<Boolean>包含关于元素是否在 observable1 中的 boolean 值包含在 observable2 中

observable1:            A ---- B ---- C ---- D
concatMapObservable:    false  true   true   false

您可以轻松地 zip这两个 observable 变成一个 observable，它将传递未包含在 observable2 中的元素。并用空字符串替换其他的

[concatMapObservable].zipWith(observable1, new Func2<Boolean, String, String>() {
    @Override
    public String call(final Boolean contains, final String string) {
        return contains ? "" : string;
    }
}

然后你过滤空字符串

[zippedObservable].filter(new Func1<String, Boolean>() {
    @Override
    public Boolean call(final String string) {
        return !TextUtils.isEmpty(string);
    }
})

---

整个代码放在一起:

Observable<String> observable1 = Observable.from(new String[]{"A", "B", "C", "D"});
Observable<String> observable2 = Observable.from(new String[]{"E", "C", "B", "G", "J", "O"});

observable1.concatMap(new Func1<String, Observable<Boolean>>() {
    @Override
    public Observable<Boolean> call(final String string) {
        return observable2.contains(string);
    }
}).zipWith(observable1, new Func2<Boolean, String, String>() {
    @Override
    public String call(final Boolean contains, final String string) {
        return contains ? "" : string;
    }
}).filter(new Func1<String, Boolean>() {
    @Override
    public Boolean call(final String string) {
        return !TextUtils.isEmpty(string);
    }
}).subscribe(new Action1<String>() {
    @Override
    public void call(final String string) {
        Log.d("observable:", string);
    }
});