2
我想弄清楚如何在Realm中使用RxJava在Realm中保存Realm对象。到目前为止,所有这些结合起来的例子都是如何从Realm中读取数据。 我想在android中使用RxJava将数据保存到Realm。任何人都可以指引我走向正确的方向。Realm + RxJava + Android:在Android中使用RxJava保存Realm对象
我想弄清楚如何在Realm中使用RxJava在Realm中保存Realm对象。到目前为止,所有这些结合起来的例子都是如何从Realm中读取数据。 我想在android中使用RxJava将数据保存到Realm。任何人都可以指引我走向正确的方向。Realm + RxJava + Android:在Android中使用RxJava保存Realm对象
public Subscription loadObjectsFromNetwork() {
return objectApi.getObjects()
.subscribeOn(Schedulers.io())
.subscribe(response -> {
try(Realm realmInstance = Realm.getDefaultInstance()) {
realmInstance.executeTransaction(realm -> realm.insertOrUpdate(response.objects));
}
});
}
https://github.com/viraj49/Realm_android-injection-rx-test –
Thanks Viraj。这是很好的信息来源,但它仍然不能解决我的问题。我想要在Realm中处理交易,同时还要记录错误和成功。如果发生错误,我希望Observer执行一些操作。 – Jay
使用beginTransaction,commitTransaction和cancelTransaction组合。使用observalble.just(cutomErrorCode)抛出自定义错误代码。 –