Дело в том что я до этого удалял и обновлял записи в Realm
таким образом:
public <T extends RealmObject> void deleteDataById(String publicId, Class<T> clazz){
Realm realm = Realm.getDefaultInstance();
realm.executeTransactionAsync(new Realm.Transaction() {
@Override
public void execute(Realm realm) {
RealmResults<T> result = realm.where(clazz).equalTo("publicId", publicId).findAll();
result.deleteAllFromRealm();
}
});
}
public <T extends RealmObject> void updateData(T object) {
try (Realm realmInstance = Realm.getDefaultInstance()) {
realmInstance.executeTransaction(realm -> {
Log.d(LOG_TAG, "updateData");
realm.insertOrUpdate(object);
});
}
}
Но так как я изучаю RXJava
, решил переделать CRUD
операции под RX
.
Вот как я делаю запись в базу:
public <T extends RealmObject> Flowable<RealmResults<T>> getAllData(Class<T> clazz) {
Realm realm = Realm.getDefaultInstance();
RealmQuery<T> query = realm.where(clazz);
if(realm.isAutoRefresh()) {
Log.d(LOG_TAG, "getData isAutoRefresh()");
return query.findAllAsync().asFlowable().filter(RealmResults::isLoaded);
} else {
Log.d(LOG_TAG, "getData, !isAutoRefresh()");
return Flowable.just(query.findAll());
}
}
С одной стороны подумываю так и оставить Update
и Delete
операции, так как они ничего не возвращают, но и с другой, мне кажется они хотя бы должны возвращать результат операции. Может я не правильно представляю.
Попробовал с Flowable.defer()
, Flowable.just()
, но все равно ошибка в flatMap()
:
flatMap (io.reactivex.functions.Function>) in Flowable cannot be applied to (anonymous io.reactivex.functions.Function)
Вот как я пытался сделать:
public Flowable deleteDataById(String publicId) {
Realm realm = Realm.getDefaultInstance();
return realm.asFlowable()
.flatMap(new Function<Realm, Boolean>() {
@Override
public Boolean apply(Realm realm) throws Exception {
return realm.where(ServiceModel.class)
.equalTo("publicId", publicId)
.findAll()
.deleteAllFromRealm();
}
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread());
}
Вопрос:
Правильны ли мои представления касательно
Update
иDelete
.Как правильно переделать
Update
иDelete
подRX
?