Rx：自动刷新列表（数组）

Question

我想实现自动刷新数组的可观察对象。我这样做：

const list$ = Observable.create(function(observer) {
  getList(list => observer.next(threads);
}));

const liveList$ = Observable.interval(2000).switchMapTo(list$);

当我对 liveList$ 流执行 subscribe 时，我仅在 n 毫秒后获得值。不出所料。

问题是如何在第一次调用 getList 后立即获取值，然后每次调用间隔时间？

P.S。我试过 $list.switchMapTo($liveList).subscribe(console.log) 但链的行为没有任何改变

Answer 1

改用 timer 运算符。它可以传递一个初始延迟，以及一个句点：

Observable.timer(0, 2000).switchMapTo(list$);

Rx：自动刷新列表（数组）

Rx: Auto-refreshing list(array)

javascript

observablecollection

observable

rxjs