java - RxJava 和 `Single` 可观察列表

Question

我是RxJava新手，所以我仍然有很多疑问。

我正在创建这个:

    @Override
    public Single<Result> saveUser(final User user) {

    return Single.create(new Single.OnSubscribe<Result>() {
        @Override
        public void call(final SingleSubscriber<? super Result> singleSubscriber) {

            if(user.isValid()){
              save(user);
              //Set result ok
              singleSubscriber.onSuccess(result);
            } else {
                //This sets an error.
                singleSubscriber.onError(error);
            }
        }
    });
}

根据操作的成功与否，Single 会发出其数据，订阅者会收到数据。

现在的问题是，在某些时候我需要存储用户列表。像这样的东西:

public void saveUsers(List<User> listOfUsers){
    for (User user : listOfUsers) {
        saveUser(user);
    }
}

如何创建 Single 以便订阅初始 Single

Answer 1

我宁愿从可观察列表中创建平面图。

public void saveUsers(List<User> listOfUsers){
    Observable.from(listOfUsers).flatMap((User user)->{
         if(user.isValid()){
           save(user);
           //Set result ok
           return Observable.just(result);
         }else
           return Observable.error(new RuntimeException("..."));
   }).retry(2);
}

如果您使 saveUsers 方法阻塞，请调用 Observable#toBlocking。