非同期タスクを介してRXJAVA - ループをループして完了を待ちます

Question

nアイテムのASYNCの作業を行い、続行する前にすべてのアイテムが完了するのを待ちます。

whatfunc?の場所に1回購読しているのは何ですか？

Observable.range(0, n)
    .<whatfunc?>({ s ->  doAsyncWorkThatReturnsObservable(s) })
    .(other?)
    .subscribe({println "All complete"})

.

ありがとう

Answer 1

href="https://github.com/netflix/rxjava/wiki/transforming-observabled#flatmap" REL="nofollow">フラットマップ

登録時に正しい引数にクローズを提供してください。提供された例で調整されたリンクからの例：

Observable.range(0, n)
    .flatMap({n -> doAsyncWorkThatReturnsObservable(n)})
    .subscribe(
       { println(it); },                          // onNext
       { println("Error: " + it.getMessage()); }, // onError
       { println("Sequence complete"); }          // onCompleted
    );

.