2

我正在尝试对n项目进行一些异步工作,并等待所有项目完成后再继续。

我应该在该whatfunc?位置放置什么以使订阅的 onComplete 触发一次?

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

谢谢

4

1 回答 1

1

平面图

确保为订阅中的正确参数提供闭包。链接示例已调整以适合您提供的示例:

Observable.range(0, n)
    .flatMap({n -> doAsyncWorkThatReturnsObservable(n)})
    .subscribe(
       { println(it); },                          // onNext
       { println("Error: " + it.getMessage()); }, // onError
       { println("Sequence complete"); }          // onCompleted
    );
于 2014-04-13T23:21:38.917 回答