0
私はToDoリストの状態管理のためにngrxストアを使用しています。rxjs observable演算子を使用すると、n秒待って結果を1つのemitにマージできますか?
私の削除アクションは、ストア内の各Todoを個別に削除します。だから私が連続して5を削除すると、店は5つの新しい発光を出します。
私は0.5のように待つことができますrxjs演算子は、すべての放射を収集し、1つにマージしますか?
おかげ
私はToDoリストの状態管理のためにngrxストアを使用しています。rxjs observable演算子を使用すると、n秒待って結果を1つのemitにマージできますか?
私の削除アクションは、ストア内の各Todoを個別に削除します。だから私が連続して5を削除すると、店は5つの新しい発光を出します。
私は0.5のように待つことができますrxjs演算子は、すべての放射を収集し、1つにマージしますか?
おかげ
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));
[ 'auditTime'](配列内のすべてのものごとに2秒を収集する必要があります/Observable.js~Observable.html#instance-method-auditTime)は必要なものに近いはずですが、マージする必要はありません。ストアの最新の状態が必要です。 – cartant