如何使用RxJava

Question

這裏是我的目標是收集異步響應：收集來自來自第三方庫的異步任務的響應

要求：使用RxJava2爲了完成

我被困在想使用哪些運營商或運營商這樣做，想法是值得讚賞的。

我的想法是：

Flowable.fromIterable(list) 
    .anOperatorCanOnNextTheResponse() 
    .buffer() 
    .subscribe(newList) 

Answer 1

最後我以PublishProcessor完成，PublishSubject也可以做的伎倆，但我跳過它們之間的區別。

val mPublishProcessor: FlowableProcessor<String> = PublishProcessor.create<String>().toSerialized() 

list.forEach { 
    doSomeAsyncTasksWithCallback(string) { 
     mPublishProcessor.onNext(string) 
    } 
} 

mPublishProcessor 
.buffer(list.size) 
.observeOn(AndroidSchedulers.mainThread()) 
.subscribe { 
    doSomethingWithTheCollectedStrings() 
}