java - 对列表中的所有项目执行一个任务，然后在 RxJava 中执行另一个任务

Question

不幸的是，我的 REST 删除操作仅适用于一项。所以我想做的是，

Observable.just(items).flatMapIterable { items -> items }.flatMap {
                //call REST DELETE for every item
            }.flatMap {
                // call REST GET
            }

问题是为每个项目调用 GET 调用。我如何等待完成所有删除完成然后执行 GET 调用？

提前致谢。

Answer 1

在您的情况下，您可以像这样应用 toList()

fun doTask(items: List<String>):Observable<Boolean>{
        return Observable.fromIterable(items)
                .flatMap { processItem(it) }
                .toList()
                .toObservable()
                .flatMap { finalTask() }
    }