如何从 Flowable 中删除存在于第二个 Flowable 中的元素?

问题描述 投票:0回答:0

我需要保存一些数据做数据库。 我有从服务器获取的数据的 Flowable,以及来自我的数据库的数据的 Flowable。 我只需要保存数据库中不存在的数据。

我尝试这样做,但我不喜欢这个阻塞部分,有没有办法以反应方式做到这一点?

var existentObjects = repository.findAll().toList().blockingGet() //Single<List<Obj>>
var newObjects = client.getObjects(); //Flowable<Obj>

return newObjects.filter(obj -> !existentObjects.contains(obj));
java rx-java rx-java2
© www.soinside.com 2019 - 2024. All rights reserved.