android - Realm DB Realm.asObservable() 发出两次结果

Question

我的应用程序使用 RxJava 和 Realm DB。当我查询 Realm 中的数据并调用 Realm.asObservable() 时，RealmResult 发出 2 次。

public class JustTest extends Activity {
    private static final String TAG = "TEST";
    private Realm realm;
    @Override
    protected void onCreate(Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        realm = Realm.getDefaultInstance();
        realm.where(Group.class).findAllAsync().asObservable()
                .subscribe(new Action1<RealmResults<Group>>() {
                    @Override
                    public void call(RealmResults<Group> groups) {
                        XLog.d(TAG, "Realm launch group result, size " + groups.size());
                    }
                });
    }

    @Override
    protected void onDestroy() {
        super.onDestroy();
        realm.close();
    }
}

日志:

TEST: Realm emits group result, size 0
TEST: Realm emits group result, size 1

Answer 1

这是设计使然，因为如果您订阅了 Realm，它会立即发出一个占位符对象。如果您只对第一个“真实”结果感兴趣，您可以这样做:

realm.where(Foo.class).findAllAsync().asObservable()
  .filter(obj::isLoaded) // isLoaded is true when query is completed
  .first() // Only get the first result and then complete
  .subscribe(...)

目前的文档并不能立即清楚这一点，但我们正在更新 JavaDoc 以更好地解释这一点:https://github.com/realm/realm-java/pull/2201