如何在 RxJava 中执行链式任务？

Question

我想在 RxJava 中一个一个地执行任务。
例如：-
1. 从服务器获取用户 ID
2.通过ID从服务器获取用户。

我试过这个方法

public Observable<List> getUids(){
       return Observable.create(emitter -> {
           List<String> uids = new ArrayList<>();
           //fetchData from server
            emitter.onNext(uids);

       });
}

public Observable<User> getUser(String uid){
       return Observable.create(emitter -> {
           User user = new User();
           //fetchData user from server
            emitter.onNext(user);
       });
}

//Executing this code like 

   getUids().flatMapIterable(ids -> ids)
               .flatMap(this::getUser)
               .subscribe(new Observer<User>() {
                 @Override
                 public void onSubscribe(Disposable d) {

                 }
                 @Override
                 public void onNext(User user) {
                   print("next "+user.getName());
                 }

                 @Override
                 public void onError(Throwable e) {
                   print("error "+e.getMessage());
                 }

                 @Override
                 public void onComplete() {
                   print("complete");
                 }
             });

里面有一些问题
1.在获取所有用户时，这不是调用订阅者的onComplete()方法。
2.如果getUser方法有错误，应用程序崩溃。 io.reactivex.exceptions.UndeliverableException 异常

你能告诉我我哪里弄错了吗？

Answer 1

1. 在您的getUids() 和getUser(...) Observables 中调用emitter.onComplete()，然后在.flatMap(this::getUser) 之后附加.toList()。

   返回一个发出单个项目的 Single，由有限源 ObservableSource 发出的所有项目组成的列表。

2. UndeliverableException 是 .flatMap(this::getUser) 中发生的异常的包装器。对于您提供的信息，我无法为您提供更多帮助，当抛出异常时您希望发生什么？