2016-08-03 64 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)); 
      } 
     }); 
}