使用 Rxjava 插入，从房间数据库中删除

Question

我正在做一个项目，我必须从房间数据库中插入和删除数据，所以基本上我使用的是旧方法，即为后台操作实现 Asynctask，但由于不再推荐，我决定使用 Rxjava相反，我试图实现它，但到目前为止我没有得到任何结果，这是一段代码，它显示了数据的插入

        Completable.fromAction(new Action() {
            @SuppressLint("CheckResult")
            @Override
            public void run() throws Exception {
                recordingDb.insertRecording(modelUidd);
            }
        }).subscribeOn(Schedulers.io());

    }

这是删除方法

 public void DeleteData(modelUidd modelUidd) {
        Completable.fromAction(new Action() {
            @Override
            public void run() throws Exception {
                recordingDb.delete(modelUidd);
            }
        }).subscribeOn(Schedulers.io());
    }

所以基本上我尝试将 Completable 与操作员 fromaction 一起使用，我不确定我实现的内容是否正确，任何帮助将不胜感激，谢谢

Answer 1

问题在于您实际上 没有订阅 observables，所以什么都没有发生。

要订阅 observable，您必须调用 .subscribe() 方法。

我建议您在 DAO 类（或“存储库”类）中定义的方法，例如您的示例中的 DeleteData，返回 Observable。然后，您可以调用 DAO 中的方法来获取 Observable 并从（理想情况下）从 ViewModel 订阅它，或者，如果没有，直接从 Activity 订阅它。在您调用subscribe 的那一刻，您将触发实际的插入或删除，并会从onSuccess 或onError 定义的回调中获得响应。

例如：

public class MyViewModel extends ViewModel {

    private MyRepository myRepository;
    private final CompositeDisposable disposables;

    @Inject
    public MyViewModel(MyRepository myRepository) {
        ...
        this.myRepository = myRepository;
        disposables = new CompositeDisposable();
        ...
    }

    public void callObservableInRepository() {
         disposables.add(myRepository.myObservable()
                              .subscribe(onSuccess -> {...} , onError -> {...}));
    }

    @Override
    protected void onCleared() {
        disposables.clear();
    }

}

您还可以查看这两个其他答案以获取更多信息：

About async operations in RxJava

Using CompositeDisposable in ViewModel