2016-08-03 4 views
2

Я пытаюсь выяснить, как сохранить объект Realm в Realm, используя RxJava в android. До сих пор весь пример, объединяющий все это, - это чтение данных из Realm. Я хочу сохранить данные в Realm, используя RxJava в android. Может ли кто-нибудь указать мне в правильном направлении.Realm + RxJava + Android: Сохранение объекта Realm с использованием RxJava в Android

+1

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

+0

Благодаря 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)); 
      } 
     }); 
} 
Смежные вопросы