我需要保存一些数据做数据库。 我有从服务器获取的数据的 Flowable,以及来自我的数据库的数据的 Flowable。 我只需要保存数据库中不存在的数据。
我尝试这样做,但我不喜欢这个阻塞部分,有没有办法以反应方式做到这一点?
var existentObjects = repository.findAll().toList().blockingGet() //Single<List<Obj>>
var newObjects = client.getObjects(); //Flowable<Obj>
return newObjects.filter(obj -> !existentObjects.contains(obj));