如何使用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() 
}