2017-07-19 92 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$);