RXJSで約束のリストを連鎖する方法は？

Question

RXJSで約束のリストをどのようにチェーン化できますか？すべての約束は、前の問題が解決されたときに実行される必要があります（仕事はステートフルです）。私はこのような何かを考えていた

const workTodo = []; // an array of work 
const allWork = Observable.create(observer => { 
    const next=() => { 
    const currentTodo = workTodo.shift(); 
    if (currentTodo) { 
     doTodoAsync(currentTodo) 
     .then(result => observer.onNext(result)) 
     .then(next); 
    } else { 
     observer.onCompleted(); 
    } 
    }; 
    next(); 
}); 

：

は

私は今それをやっている方法は、原始的な感じ

const workTodo = []; // an array of work 
const allWork = Observable 
        .fromArray(workTodo) 
        .flatMap(doTodoAsync); 

をしかし、それは基本的に一度にすべての約束を実行します。

Answer 1

再帰についてはどうですか？

まず再帰関数を作成し、recursiveDoToDoそれを呼び出す：

const recursiveDoToDo = (currentTodo, index) => 
    Observable 
     .fromPromise(doTodoAsync(currentTodo)) 
     .map(resolved => ({resolved, index})); 

コードを上だけで観察可能にあなたのdoTodoAsyncをラップして、私たちが解決を約束を返すように結果をマップしのindex配列、後で再帰的に使用する。

次に、.expand()演算子を使用してrecursiveDoToDoを再帰的に呼び出します。

recursiveDoToDo(worktodo[0], 0) 
    .expand(res => recursiveDoToDo(worktodo[res.index + 1], res.index + 1)) 
    .take(worktodo.length) 

長さである、あなたの再帰を行うために必要なすべての.expand()を再帰的に永遠に実行されますのでちょうど1によってインデックスをインクリメントすることで、.take()オペレータは、ストリームを終了するときに観察を伝えることがあり、あなたのworktodoの

今、あなたは、単にそれを購読することができます：

recursion.subscribe(x => console.log(x)); 

をここではあなたがあなたの試みとかなり接近していたようだworking JS Bin

Answer 2

です。

あなたは同じよう.flatMapのために1の最大同時実行数を指定することができ、次のいずれか

Observable.fromArray(workTodo) 
.flatMap(doTodoAsync, 1) 

または同等.concatMapの代わり.flatMapを使用します。

Observable.fromArray(workTodo) 
.concatMap(doTodoAsync) 

それはより多くの慣用感じているように私はconcatMapを使用します。

UPDATE：DEMO