RxJs：観測対象の状態に基づいてどのようにループするのですか？

Question

私は、特定の状態になるまでRxJsをObservableにループさせようとしています。具体的には、同期do/whileループをRxJsに変換していますが、forやwhileループでも同じ答えが使用できると仮定しています。

私はこれにdoWhile（）を使うことができると思っていましたが、条件関数がストリーム内のアイテムにアクセスできないように思えます。

私は正しい反応性の用語は、私が欲しいものですが、ここで私はつもりかの例が何であるかを完全にはよく分からない：

var source = new Rx.Observable.of({val: 0, counter: 3}); 

source.map(o => { 
    o.counter--; 
    console.log('Counter: ' + o.counter); 

    if (!o.counter) { 
    o.val = "YESS!"; 
    } 
    return o; 
}) 
.doWhile(o => { 
    return o.counter > 0; 
}) 
.subscribe(
    function (x) { 
     console.log('Next: ' + x.val); 
    }, 
    function (err) { 
     console.log('Error: ' + err); 
    }, 
    function() { 
     console.log('Completed'); 
    }); 

予想される出力は次のようになります。

Counter: 3 
Counter: 2 
Counter: 1 
Counter: 0 
Next: YESS! 
Completed 

これは解決可能な問題であると仮定し、ループ時に戻したい場所の「開始」をどのようにマークするかは不明です。

Answer 1

expand演算子があります。セレクタ関数を再帰的に呼び出すことができます。空の観察可能なものを返すことは、その場合のあなたの休憩でしょう。 jsbinを参照してください：

var source = Rx.Observable.return({val: 0, counter: 3}) 
    .expand(value => { 
     if(!value.counter) return Rx.Observable.empty(); 
     value.counter -= 1; 
     if(!value.counter) value.val = 'YESS'; 
     return Rx.Observable.return(value) 
    }) 
    .subscribe(value => console.log(value.counter ? 
            'Counter: ' + value.counter : 
            'Next: ' + value.val)); 

Answer 2

ない正確に何をしたいが、近く、expand演算子を使用して、そしてRx.Observable.empty（http://jsfiddle.net/naaycu71/3/）と再帰の終了を知らせる：

var source = new Rx.Observable.of({val: 0, counter: 3}); 

source.expand(function(o) { 
    console.log('Counter: ' + o.counter); 
    o.counter--; 

return (o.counter >= 0) ? Rx.Observable.just(o) : Rx.Observable.empty() 
}) 
.subscribe(
    function (x) { 
     console.log('Next: ' , x); 
    }, 
    function (err) { 
     console.log('Error: ' + err); 
    }, 
    function() { 
     console.log('Completed'); 
    }); 

出力：

Next: Object {val: 0, counter: 3} 
Counter: 3 
Next: Object {val: 0, counter: 2} 
Counter: 2 
Next: Object {val: 0, counter: 1} 
Counter: 1 
Next: Object {val: 0, counter: 0} 
Counter: 0 
Completed