2016-08-03 131 views
2

我想弄清楚如何在Realm中使用RxJava在Realm中保存Realm对象。到目前为止,所有这些结合起来的例子都是如何从Realm中读取数据。 我想在android中使用RxJava将数据保存到Realm。任何人都可以指引我走向正确的方向。Realm + RxJava + Android:在Android中使用RxJava保存Realm对象

+1

https://github.com/viraj49/Realm_android-injection-rx-test –

+0

Thanks Viraj。这是很好的信息来源,但它仍然不能解决我的问题。我想要在Realm中处理交易,同时还要记录错误和成功。如果发生错误,我希望Observer执行一些操作。 – Jay

+1

使用beginTransaction,commitTransaction和cancelTransaction组合。使用observalble.just(cutomErrorCode)抛出自定义错误代码。 –

回答

1
public Subscription loadObjectsFromNetwork() { 
    return objectApi.getObjects() 
     .subscribeOn(Schedulers.io()) 
     .subscribe(response -> { 
      try(Realm realmInstance = Realm.getDefaultInstance()) { 
       realmInstance.executeTransaction(realm -> realm.insertOrUpdate(response.objects)); 
      } 
     }); 
}