2017-07-19 96 views
0

我想实现自动刷新自身的数组的可观察性。我不喜欢这样写道:Rx:自动刷新列表(阵列)

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

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

当我做subscribeliveList$流我只后n毫秒得到的值。如预期。

问题是我怎样才能得到值立即第一次打电话getList和每间隔下次打电话?

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

回答

0

改为使用timer运算符。它可以通过一个初始延迟,以及一段时间:

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