不幸的是，我的 REST 刪除操作僅適用于一項。所以我想做的是，Observable.just(items).flatMapIterable { items -> items }.flatMap { //call REST DELETE for every item }.flatMap { // call REST GET }問題是正在為每個項目調(diào)用 GET 調(diào)用。我如何等待完成所有刪除完成然后執(zhí)行 GET 調(diào)用？提前致謝。
3 回答
四季花海
TA貢獻1811條經(jīng)驗 獲得超5個贊
在你的情況下，你可以toList()這樣申請
fun doTask(items: List<String>):Observable<Boolean>{
return Observable.fromIterable(items)
.flatMap { processItem(it) }
.toList()
.toObservable()
.flatMap { finalTask() }
}
米琪卡哇伊
TA貢獻1998條經(jīng)驗 獲得超6個贊
這個問題可以用zip解決。如果有人想要這個
fun doTask(items: ArrayList<String>): Observable<Boolean> {
val list = arrayListOf<Observable<String>>()
items.forEach {
list.add(processItem(it))
}
return Observable.zip(list) {
}.flatMap {
finalTask()
}
}
fun processItem(s: String): Observable<String> {
print(s)
return Observable.just(s.toUpperCase())
}
fun finalTask(): Observable<Boolean> {
print("final")
return Observable.fromCallable { true }
}
一只萌萌小番薯
TA貢獻1795條經(jīng)驗 獲得超7個贊
Observable.just("one", "two", "three", "four", "five").subscribe(new Consumer<String>() {
@Override
public void accept(String s) throws Exception {
Log.d("ffff", s);//print: one, two, three, four, five
}
}, new Consumer<Throwable>() {
@Override
public void accept(Throwable throwable) throws Exception {
}
}, new Action() {
@Override
public void run() throws Exception {
Log.d("ffff", "complete");//print: complete
}
});
添加回答
舉報
0/150
提交
取消