Realm Java 0.87 — with RxJava support!

我们刚刚发布了最新版本的Realm并上传到了Maven。这个第一个支持RxJava的版本。

RxJava

RxJava是Netflix出品的一个扩展了观察者模式的响应式框架类库。它让通过组合操作符的方式来改变Realm数据变成了可能。目前除了RealmQuery和RealmList以外的其它Realm类都可以转换成Observable.

Realm的Observable建立在标准的RealmChangeListener之上，所以任何Observable发送事件的速率与ChangeListener的通知速率保持一致。

Realm realm = Realm.getDefaultInstance();
RealmResults<Person> persons = realm.where(Person.class).findAll();
Person person = persons.first();
Observable<Realm> realmObservable = realm.asObservable();
Observable<RealmResults<Person>> resultsObservable = persons.asObservable();
Observable<Person> objectObservable = person.asObservable();

同样适用于Realm的异步API：

realm.where(Person.class).equalTo("name", "John").findAllAsync().asObservable()
  .filter(new Func1<RealmResults<Person>, Boolean>() {
      @Override
      public Boolean call(RealmResults<Person> persons) {
          // Ignore unloaded results
          return persons.isLoaded();
      }
  })
  .subscribe(new Action1<RealmResults<Person>>() {
      @Override
      public void call(RealmResults<Person> persons) {
          // Show persons...
      }
  });

更多用例请阅读RxJava example project

配置

尽管RxJava在我们的API中能够表现良好，但它始终是个opt-in依赖，这就意味着需要在build.gradle中手动添加RxJava依赖。这样做的好处就是完全由你决定使用RxJava的哪个版本，并且能够在不需要使用RxJava的项目中避免方法数量溢出的问题。

dependencies {
  compile 'io.realm:realm-android:0.87.0'
  compile 'io.reactivex:rxjava:1.1.0'
}

我们为那些想自定义创建Observable方式的同学提供了一个叫做RxObservableFactory的新接口。可以使用RealmConfiguration配置自定义factory，但是Realm自带一个默认RealmObservableFactory，只能在RxJava 1.1.*以下使用。

RealmConfiguration config = new RealmConfiguration.Builder(context)
  .rxFactory(new MyFactory())
  .build()

开发中版本

现在我们只是实现了对RxJava的初步支持，遗憾的是仍不支持将RealmQuery和RealmList转换成Observable。不过这些新特性将被添加到以后的更新中。

需要特别记住的是RealmObject和RealmResults是受线程约束的。这就意味着不能在一个线程中加载Realm对象而在另一个线程中使用。

// Default pattern for loading data on a background thread
Observable.defer(new Func0<Observable<RealmResults<Person>>>() {
    @Override
    public Observable<RealmResults<Person>> call() {
        return realm.where(Person.class).findAll().asObservable();
    }
})
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Action1<RealmResults<Person>>() {
    @Override
    public void call(RealmResults<Person> persons) {
        // Accessing persons here would crash.
    }
});
// Instead, use Realms Async API for the same effect
realm.where(Person.class).findAllAsync().asObservable()
  .subscribe(new Action1<RealmResults<Person>>() {
      @Override
      public void call(RealmResults<Person> persons) {
          // Show data in the UI
      }
  });

RealmObject和RealmResult都是活动对象，也就是说它们会不断地更新从而与Realm中的最新数据保持一致。这种一致性真的很伟大，但是目前还不支持不可变的线程安全对象，因此不能与RxJava模型友好的协同工作。所以，我们又添加了Realm.copyFromRealm()方法，它可以将Realm数据复制到标准Java对象中，把它们有效地从Realm中分离出来。虽然会造成一定的延迟和内存开销，但是这样做就能够更容易的与操作符一起工作了，比如.buffer()。

// Get different versions of a person
realm.where(Person.class).findFirst().<Person>asObservable()
        .map(new Func1<Person, Person>() {
            @Override
            public Person call(Person person) {
                // Convert live object to a static copy
                return realm.copyFromRealm(person);
            }
        })
        .buffer(2)
        .subscribe(new Action1<List<Person>>() {
            @Override
            public void call(List<Person> persons) {
                // Without `map` and `copyFromRealm`, v1 and v2 would be the same
                Person v1 = persons.get(0);
                Person v2 = persons.get(1);
            }
        });

更好的解决方案将被添加到未来的更新中。

了解所有细节请查看完整的更新日志。