创建一个可观察列表流Rxjava 2

Question

我有一个id列表，并且有一个方法，它接受id并返回可观察的

假设我有用户id（1），我需要使用此方法更新他的配置文件可观察

我现在需要的是为多个id创建方法，如果所有概要文件都更新了，则返回true。它可能具有此特征

如何实现这样的目标？




Answer 1

  Observable<Boolean> updateAllProfiles(Integer[] ids) {
    return Observable.from(ids)
        .flatMap(id -> updateProfile(id))
        .all(success-> success);
  }

Answer 2

假设要单独更新每个概要文件，并在所有更新结束后返回true，则可以使用flatMap和reduce的组合：

Observable<Boolean> updateAllProfiles(Integer[] ids) {
    return Observable.from(ids)
            .flatMap(id -> updateProfile(id))
            .reduce((prevResult, currResult) -> prevResult && currResult);
}

以及用途：

updateAllProfiles(new Integer[]{0, 1, 2, 3, 4})
            .subscribe(updateAllSucceed -> { //do something with result});

这将并行触发所有更新（假设每个更新配置文件都将作用于Scheduler.io或创建新线程的类似文件），并将累积所有结果指示并相应地返回true/false。
顺便说一句，您可能需要考虑完整的而不是可观察的