java RxJava无重复合并

Question

我对RxJava有点陌生，我正在尝试实现搜索本地数据库和服务器的搜索功能。我想它合并两个结果，并消除重复，任何想法

Answer 1

您可以合并本地和远程结果，并使用toMap消除重复项

此外，如果您有更多的需求，可以使用collect和HashSet（或HashMap），这会给您更多的控制：

    Observable<Integer> local = Observable.just(1, 2, 3, 4);
    Observable<Integer> remote = Observable.just(1, 3, 5, 7);
    local.mergeWith(remote)
            .collect(() -> new HashSet<Integer>(), (set, v) -> set.add(v))
            .flatMap(Observable::from)
            .subscribe(System.out::println);

Answer 2

你可以使用distinct operator