RxJSを使用して一度に1つずつサーバーに要求を送信する

Question

ペイロードの配列があります。それぞれに非同期アクションをいくつか実行してから、サーバーに送信します。その後、

Rx.Observable.from(payloads) 
    .flatMap(item => ... do something A something async, return modified payload) 
    .flatMap(item => ... do something B) 
    .flatMap(item => ... post to server) 
    .subscribe(); 

これは動作します....

しかし、すべてを一度に各ペイロードのためにB、その後、一斉に各ペイロードのためにやっているようだ。私はこのようにそれをやろうとしています各ペイロードを一度に投稿する。

潜在的に何千ものペイロードのリストがあります。一度に1つずつ、ペイロードを通過する方法はありますか？

Answer 1

彼らはそれぞれのペイロードのA-> B-> Cを行うことが必要な場合：以前の排出量は次の開始前に完了するまで

Rx.Observable.from(payloads) 
    .concatMap(payload => doA()) 
    .concatMap(resA => doB()) 
    .concatMap(resB => doC()) 
    .subscribe(console.log) 

concatMapをお待ちしております。これにより、並行性が制限されます。