RxJS5は時間の経過とともに配列アイテムを放出し、永遠に繰り返す

Question

時間がたつにつれて配列アイテムを放出したい（各放出の間に1秒の間隔を置いて）、すべてのアイテムが放出されたら何度も何度も繰り返す。

..

"1" ..

出力がある

const MY_ARRAY = ['one','two','three']; 
const item$ = Rx.Observable.interval(1000).take(MY_ARRAY.length).repeat().map(x => MY_ARRAY[x]); 
item$.subscribe(x => console.log(x)); 

おかげで、私はこれを行う方法を知っているが、私はより簡潔なものがあるかどうかを知りたいです

「two」

"t HREE」

"1"

"2"

"3"

など

EDIT：

ATOW、ここでの回答は次のように要約されています。..

const ARR = ['one', 'two', 'three']; 

// TAKE YOUR PICK THEY ALL DO THE SAME 
const item$ = Rx.Observable.interval(1000).map(i => ARR[i % ARR.length]); 
// const item$ = Rx.Observable.interval(1000).zip(ARR, (a, x) => x).repeat(); 
// const item$ = Rx.Observable.interval(1000).zip(ARR).repeat().map(x => x[1]); 
// const item$ = Rx.Observable.interval(1000).take(ARR.length).repeat().map(i => ARR[i]); 

item$.subscribe((x) => { 
    console.log(x); 
}); 

Answer 1

Observable.interval(1000).map(i => MY_ARRAY[i % MY_ARRAY.length]) 

Answer 2

あなたはジップ演算子を使用することができます。

const interval$ = Rx.Observable.interval(1000); 
const items$ = Rx.Observable.from([1,2,3]); 

const itemsOverTime$ = interval$.zip(items$).repeat(); 


itemsOverTime$.subscribe(([time, val]) => { 
    console.log(val); 
    // 1 
    // 2 
    // 3 
    // 1 
    // 2 
    // 3 
}); 

Answer 3

zipがgo-にオペレーターここにあるが、Observable.fromを使用すると、サブスクライブ上のすべての値をダンプし、値のコピーを保持するために郵便番号が必要です。これは、大規模な配列には理想的ではありません。 zipの元のIEnumerable<T>は、zipIterableとして実装されています。

const MY_ARRAY = ['one','two','three']; 
Rx.Observable.interval(1000).zipIterable(MY_ARRAY, (_, v) => v).subscribe(v => console.log(v))