rxjsを使ったオブジェクトの遅延と反復

Question

オブジェクト内のキーをループして、あるキーと別のキーとの間に設定された間隔で反復しようとしています。 私は間隔演算子を使用してこれを達成しようとしていますが、そうすることで失敗しました。

let obj = { 'a': [1,23,3], 'b': [12,23,2] }; 
for(let key in data) { 
     Observable.interval(5000).subscribe(() => { 
     // perform operation with data[key]  
     }); 
    } 

私は私のループ間のいずれかの遅延が表示されていないと私は取得していますすべては、通常のループbeahviorと変わらない突然の繰り返しです。

Answer 1

これは、各繰り返しで新しいObservableを作成するためです。実際の遅延がconcatMapによって行われる

Observable.from(Object.keys(obj)) 
    .concatMap(item => Observable.of(item).delay(5000)) 
    .subscribe(item => console.log(item)); 

次のいずれかに加入する前に、それぞれの内側の観察可能完了するまで待機します：

は、私はあなたがこのようなものを作りたかったと思います。

Answer 2

zip演算子とタイマー演算子を使用できます。タイマーはarg 0の区間と似ています - すぐに発光を開始します。

let obj = { 'a': [1,23,3], 'b': [12,23,2] }; 

Rx.Observable.zip(
    Rx.Observable.timer(0, 5000), 
    Rx.Observable.from(Object.entries(obj)), 
    (timer,val)=>val 
) 
.subscribe(x=>console.log(x))