在可观察结果RxJava之后运行DB Update方法

Question

应用程序：我有一个非常基本的应用程序，它有一些机器（名称、id、total\u income）和一些收入（id、money、note、Machines\u id）。在第一个屏幕上，我允许用户从一个工厂添加一台机器，然后我将其显示在RecyclerView中。当用户单击任何一台机器时，我将其导航到第二个屏幕，在那里用户可以看到机器的名称、总收入和一个RecyclerView及其相应的收入；有一家工厂可以让他们为那台机器增加收入，并刷新RecyclerView。

问题是：我一直未能将传统世界转换为RxJava。

我已经设法使它工作使用的房间。allowMainThreadQueries（）和常规方法。

机器设备模型

public long updateByID(long id, double total_income){
    return machinesDB.getMachineDAO().updateMachineByID(id, total_income);
}

机械DAO

@Query("update machines set total_income = :total_income where id = :id")
int updateMachineByID(long id, double total_income);

MachineInfo活动

disposable.add(incomeViewModel.getIncomeOfMachine(id)
             .defaultIfEmpty(0.0)
             .subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe(total_amount -> {
                     if (total_amount != null) {
                        // This works correctly using .allowMainThreadQueries() and conventional methods
                        machineViewModel.updateByID(id, total_amount);

                        DecimalFormat formatter = new DecimalFormat("$#,##0.000");
                        String formatted = formatter.format(total_amount);
                        mMoney.setText(formatted);

                        Toast.makeText(this, "MachineInfo: " + String.valueOf(machineViewModel.updateByID(id, total_amount)), Toast.LENGTH_SHORT).show();

                         showMenu = true;
                     } else {
                         mMoney.setText("$0.0");
                     }
             }, throwable -> Log.e(TAG, "MachineInfo: ERROR", throwable )));

我知道Room需要在后台线程中实例化，这就是我使用RxJava的原因。但是，当我尝试将上述方法转换为RxJava世界时，就像下面的方法一样，我没有更新，但没有崩溃，“从未使用该方法的返回值”。

机器设备模型

public Completable updateByID(long id, double total_income){
    return Completable.fromAction(() -> machinesDB.getMachineDAO().updateMachineByID(id, total_income));
}

机械DAO

@Query("update machines set total_income = :total_income where id = :id")
int updateMachineByID(long id, double total_income);

尝试#1：失败

private PublishSubject<Double> publishSubject = PublishSubject.create();
private Observable<Double> clickEvent = publishSubject;

/*
/ other stuff in here
*/

disposable.add(incomeViewModel.getIncomeOfMachine(id)
            .defaultIfEmpty(0.0)
            .subscribeOn(Schedulers.io())
            .observeOn(AndroidSchedulers.mainThread())
            .subscribe(total_amount -> {
                        if (total_amount != null) {

                            publishSubject.onNext(total_amount);

                            DecimalFormat formatter = new DecimalFormat("$#,##0.000");
                            String formatted = formatter.format(total_amount);
                            mMoney.setText(formatted);
                            showMenu = true;
                        } else {
                            mMoney.setText("$0.0");
                        }
                    }, throwable -> Log.d(TAG, "MachineInfo: ERROR")));

    disposable.add(clickEvent.subscribe(
            total_amount -> machineViewModel.updateByID(id, total_amount)));

尝试#2：失败

机器设备模型

public Completable updateByID(long id, double total_income){
    return Completable.fromCallable(() -> machinesDB.getMachineDAO().updateMachineByID(id, total_income));
}

机械DAO

@Query("update machines set total_income = :total_income where id = :id")
int updateMachineByID(long id, double total_income);

MachineInfo活动

disposable.add(incomeViewModel.getIncomeOfMachine(id)
             .defaultIfEmpty(0.0)
             .subscribeOn(Schedulers.io())
             .observeOn(AndroidSchedulers.mainThread())
             .subscribe(total_amount -> {
                     if (total_amount != null) {
                        // Completable.fromCallable()
                        machineViewModel.updateByID(id, total_amount);

                        DecimalFormat formatter = new DecimalFormat("$#,##0.000");
                        String formatted = formatter.format(total_amount);
                        mMoney.setText(formatted);

                        Toast.makeText(this, "MachineInfo: " + String.valueOf(machineViewModel.updateByID(id, total_amount)), Toast.LENGTH_SHORT).show();

                         showMenu = true;
                     } else {
                         mMoney.setText("$0.0");
                     }
             }, throwable -> Log.e(TAG, "MachineInfo: ERROR", throwable )));

Answer 1

好吧，多亏了迈克尔，我才找到了问题的症结所在。

所以很明显，你可以在一次性用品中添加一次性用品。

>

您需要初始化可观察对象并添加其。观察（等）。订阅（等）。订阅（etc）“

将一次性用品添加到一次性用品中，如下所示：

disposable.add(incomeViewModel.getIncomeOfMachine(id)
        .defaultIfEmpty(0.0)
        .subscribeOn(Schedulers.io())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(total_amount -> {
                    if (total_amount != null) {

                        disposable.add(machineViewModel.updateByID(id, total_amount)
                                .subscribeOn(Schedulers.io())
                                .observeOn(AndroidSchedulers.mainThread())
                                .subscribe(
                                        () -> Log.d(TAG, "MachineInfo: COMPLETED"),
                                        throwable -> Log.e(TAG, "MachineInfo: ERROR", throwable )));

                        DecimalFormat formatter = new DecimalFormat("$#,##0.000");
                        String formatted = formatter.format(total_amount);
                        mMoney.setText(formatted);
                        showMenu = true;
                    } else {
                        mMoney.setText("$0.0");
                    }
                }, throwable -> Log.d(TAG, "MachineInfo 2: ERROR")));

我注意到，如果是一个干净的答案，但它是有效的。

Answer 2

你说失败是什么意思？数据库是否没有更新，或者您是否遇到了一些异常？

无论如何，我看到的主要问题是，您没有订阅可完成的对象-没有这一点，它们将无法执行。

So更改：

machineViewModel.updateByID(id, total_amount);

到例如：

machineViewModel.updateByID(id, total_amount).subscribeOn(Schedulers.io()).observeOn(Schedulers.io()).subscribe();

而且它会起作用（当然，您可能想向subscribe方法添加特定的订阅者）。