android - 领域异步事务执行后返回 Completable

Question

我正在使用领域 3.4 和 rx java2。我想要完成的是在将数据插入领域后返回一个 Completable。

public Completable insertSamplesRx(final List<Sample> sampleList) {
    realm.executeTransactionAsync(new Realm.Transaction() {
        @Override
        public void execute(Realm realm) {
            for(Sample s : sampleList) {
                realm.insertOrUpdate(sampleList);
            }
        }
    }, new Realm.Transaction.OnSuccess() {
        @Override
        public void onSuccess() {
            Completable.complete();
        }
    }, new Realm.Transaction.OnError() {
        @Override
        public void onError(Throwable error) {
            Completable.error(error);
        }
    });
}

这段代码显然无法编译，因为缺少返回值。我如何在这里返回可完成的结果？

谢谢

Answer 1

重要的是要记住，在 subscribe 被调用之前，Rx 对象通常不会做任何事情。

你应该看看Completable.create查看如何将“操作”转换为可以完成或导致错误的 Completable。