2017-09-21 6 views
0

私はToDoリストの状態管理のためにngrxストアを使用しています。rxjs observable演算子を使用すると、n秒待って結果を1つのemitにマージできますか?

私の削除アクションは、ストア内の各Todoを個別に削除します。だから私が連続して5を削除すると、店は5つの新しい発光を出します。

私は0.5のように待つことができますrxjs演算子は、すべての放射を収集し、1つにマージしますか?

おかげ

+0

[ 'auditTime'](配列内のすべてのものごとに2秒を収集する必要があります/Observable.js~Observable.html#instance-method-auditTime)は必要なものに近いはずですが、マージする必要はありません。ストアの最新の状態が必要です。 – cartant

答えて

2

bufferTimeにしてみて、空の値を飛ばし、それがhttp://reactivex.io/rxjs/class/es6

var clicks = Rx.Observable.fromEvent(document, 'click').mapTo('clicked') 
var buffered = clicks.bufferTime(2000).filter(value=>value.length>0); 
buffered.subscribe(x => console.log(x));