2017-07-19 5 views
0

自己監視を自動更新する配列observableを実装したいと思います。私は私だけnミリ秒後の値を取得liveList$ストリームにsubscribeを行うとRx:自動リフレッシュリスト(配列)

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

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

:私はこのようにそれを行います。予想通り。

質問は、すぐにgetListの最初の呼び出しの後に値を取得し、次の各呼び出しで間隔を取得する方法はありますか?

P.S.私は$list.switchMapTo($liveList).subscribe(console.log)にしようとしましたが、チェーンの動作に何も変わりません

答えて

0

代わりにtimer演算子を使用してください。最初の遅延だけでなく期間も渡すことができます。

Observable.timer(0, 2000).switchMapTo(list$); 
関連する問題