2

我正在努力通过 RxJava2。我想知道我的解决方案是否可以接受，或者有什么方法可以改进它。

用例

  1. 用户按下更新数据按钮
  2. 显示一个对话框 - 请稍候
  3. 多个后端调用并行处理
  4. 一旦完成任何这些 - 数据将保存在本地数据库中
  5. 在所有请求完成后（后端调用和持久化），对话框应该被关闭

当前解决方案

我有几个Completables看起来像这样：

Completable organisationUnitCompletable = backendService.getOrganisationUnits()
    .doOnNext(data -> organisationUnitDao.saveInTx(data))
    .ignoreElements()
    .subscribeOn(Schedulers.io());

Completable locationCompletable = backendService.getLocations()
    .doOnNext(data -> locationDao.saveInTx(data))
    .ignoreElements()
    .subscribeOn(Schedulers.io());

Completable prioritiesCompletable = backendService.getPriorities()
    .doOnNext(data -> priorityDao.saveInTx(data))
    .ignoreElements()
    .subscribeOn(Schedulers.io());

我通过添加到列表并使用运算符将​​它们打包成一个merge：

List<Completable> compatibles = new ArrayList<>();
compatibles.add(organisationUnitCompletable);
compatibles.add(locationCompletable);
compatibles.add(prioritiesCompletable);

Completable.merge(compatibles)
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(() -> {
     progressDialog.dismiss();
});

可能的改进

好的，所以这按预期工作。但有些事情我并不那么高兴。

我真的必须添加subscribeOn(Schedulers.io())到每个 Completable 吗？没有它就不能并行工作，但也许有更好的方法来做到这一点？

所有可完成项都有这些行。

    .ignoreElements()
    .subscribeOn(Schedulers.io());

有没有办法将它提取到一种方法中？我试过这样的事情：

private <T> Completable prepareCompletable(Function<Void, Observable<List<T>>> source, AbstractDao<T, Long> dao) {

    Completable orderTypeCompletable = source
            .doOnNext(data -> dao.saveInTx(data))
            .ignoreElements()
            .subscribeOn(Schedulers.io());
}

我只是将 Observable 和 DAO 放入其中。当然编译不了。似乎它需要的泛型知识比我已经拥有的要多得多。

抱歉，这个问题很长，很难用几句话来解释整个用例。

4

1 回答 1

2

我真的必须将 subscribeOn(Schedulers.io()) 添加到每个 Completable 吗？

是的，但之后你不需要它Completable.merge()。

有没有办法将它提取到一种方法中？

public static <T> Function<Flowable<T>, Completable> applyIgnore() {
    return f -> f.ignoreElements().subscribeOn(Schedulers.io());
}

Completable locationCompletable = backendService.getLocations()
.doOnNext(data -> locationDao.saveInTx(data))
.to(applyIgnore());
于 2016-11-26T18:56:49.593 回答