android - Realm + RxJava + Android : Saving Realm object using RxJava in Android

Question

我试图弄清楚如何在android中使用RxJava在Realm中保存Realm对象。到目前为止，所有结合所有这些的示例都是如何从 Realm 读取数据。 我想在android中使用RxJava将数据保存到Realm。任何人都可以指出我正确的方向吗？

Answer 1

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