RxJS5 随着时间的推移发出数组项并永远重复

Question

我想随着时间的推移发射数组项目（每次发射之间间隔一秒），当所有项目都发射完毕后，一遍又一遍地重复。

我知道该怎么做，但我想知道是否有比..更简洁的东西。

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));

谢谢

输出是..

“一个”

“两个”

“三”

“一个”

“两个”

“三”

等

编辑：

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

您可以使用 zip 运算符：

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 是这里的首选运算符，但使用 Observable.from 会在订阅时转储所有值，并且需要 zip 来保留值的副本。这对于大型阵列并不理想。 zip 的原始 IEnumerable<T> 重载实现为 zipIterable。

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

Answer 4

使用zip 组合来自interval 和from 的流，这样对于每个间隔时间，都会发出一个值。然后你用repeat 操作符将上面的 observable 管道化，不带参数永远发出值。

const { interval, from, zip } = require('rxjs');
const { repeat } = require('rxjs/operators')

const itemsOverTime$ = zip(
    interval(1000),
    from(MY_ARRAY)
).pipe(repeat());

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