在RxJava中从2个可观察到的项目列表中创建一个过滤后的可观察到的

Question

我正在开发一个功能，我需要根据本地数据库数据过滤掉网络响应数据。

例如，我的网络层返回一个项目列表，我的数据库层返回一个可观察的ID列表。现在，我只想从网络层返回那些id与数据库层响应中的任何人都匹配的对象。

下面的代码从网络获取数据并将结果保存到数据库（缓存）。

factory.getRemoteDataStore()
                .searchForVenues(query)
                .toObservable()
                .distinctUntilChanged()
                .flatMap { venues ->
                    factory.getCacheDataStore()
                            .saveVenues(venues)
                            .andThen(Observable.just(venues))
                }

我还有一个方法可以返回需要过滤的场馆列表

factory.getCacheDataStore().getDislikedVenues()

现在，我如何扩展前面的链，使用getDislikedVinces（）observate从网络响应的响应中过滤它们？

很抱歉提出这样的问题，我真的很难回答。

Answer 1

这样做的一种方法是

factory.getCacheDataStore().getDislikedVenues()
    .flatMap { dislikedItems -> 
        factory.getRemoteDataStore()
            .searchForVenues(query)
            .toObservable()
            .distinctUntilChanged()
            .flatMapIterable { it }
            .filter { !dislikedItems.contains(it.id) }
            .toList()
            .toObservable()
    }
    .flatMap { venues ->
        factory.getCacheDataStore()
            .saveVenues(venues)
            .andThen(Observable.just(venues))
    }

P、 据我所知，工厂。getRemoteDataStore（）。SearchForVinces（查询）返回单个或可能的。在这种情况下，distinctUntilChanged（）不起作用，因为它依赖于多个发射（onNext（）），但单个或可能只能发射一个结果。