java - Android RxJava 将嵌套的自定义列表组合在一个列表中

Question

层次结构

List<Job> myJob; // consider both list as not empty

List<Tasks> myTasks = myJob.getTasks();

我现在使用下面的代码

  Observable.just(myJob)
                    .subscribeOn(Schedulers.computation())
                    .concatMap(Observable::fromIterable)
                    .subscribe(new DefaultObserver<Job>() {
                        @Override
                        public void onNext(@NonNull Job myJob) {
                            Log.d(Utils.APP_LOG,
                                    "Total Task: \n " +
                                     "Job id-" + myJob.getJobId()
                                     + "tasks-" + myJob.getTasks().size());

                        }

                        @Override
                        public void onError(@NonNull Throwable e) {

                        }

                        @Override
                        public void onComplete() {

                        }
                    });

我能够获得父(我的工作)列表和子(任务)列表。现在我想将每个作业的任务列表合并到一个列表中。

我尝试使用 This accepted answer 执行查询但在我的场景中，作业(父)列表大小和任务(子)列表大小都是动态的。

Answer 1

Single<List<Tasks>> taskObservable = Observable.fromIterable(myJob)
            .flatMapIterable(Job::getTasks)
            .toList();

上面的代码将执行以下操作:

1. 获取您的作业列表并将其转换为发出 Jobs
的流
2. 对于每个作业，将其转换为发出 Tasks
的流
3. 将所有发出的任务收集到一个列表中并发出该 List