不幸的是,我的 REST 删除操作仅适用于一项。所以我想做的是,
Observable.just(items).flatMapIterable { items -> items }.flatMap {
//call REST DELETE for every item
}.flatMap {
// call REST GET
}
问题是为每个项目调用 GET 调用。我如何等待完成所有删除完成然后执行 GET 调用?
提前致谢。
最佳答案
在您的情况下,您可以像这样应用 toList()
fun doTask(items: List<String>):Observable<Boolean>{
return Observable.fromIterable(items)
.flatMap { processItem(it) }
.toList()
.toObservable()
.flatMap { finalTask() }
}
关于java - 对列表中的所有项目执行一个任务,然后在 RxJava 中执行另一个任务,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/57404599/