RXJS：集約デバウンス

Question

私のユースケースは以下の通りです：私はときどきバースト的に発生するイベントを受け取ります。バーストが発生した場合、私は一度だけそれを処理する必要があります。 Debounceがこれを行います。

しかし、debounceは私にバーストの最後の要素を与えますが、バースト内のすべての要素について（フラットマップを使用して）集約する必要があります。

これはタイムドウインドウまたはバッファで行うことができますが、これらは固定間隔なので、バーストの途中でバッファ/ウィンドウタイムアウトが発生する可能性があるため、バーストを2つに分割して1の代わりに処理します。

だから、あなたは、おそらくページからbufferWithTimeOrCount

探しているものを私がしたいと思うことは

. 
. 
event: a 
. 
. -> a 
. 
. 
. 
. 
. 
.event: b 
.event: c 
.event: d 
. 
.-> b,c,d 
. 
. 
. 
. 
.event : e 
. 
. -> e 
. 

Answer 1

これは、例えば、クロージングセレクタとしてでデバウンスストリームを渡すことによってbufferで達成することができます。：

var s = Rx.Observable.of('a') 
    .merge(Rx.Observable.of('b').delay(100)) 
    .merge(Rx.Observable.of('c').delay(150)) 
    .merge(Rx.Observable.of('d').delay(200)) 
    .merge(Rx.Observable.of('e').delay(300)) 
    .share() 
; 

s.buffer(s.debounce(75)).subscribe(x => console.log(x)); 

ここで実行可能なバージョンです：https://jsbin.com/wusasi/edit?js,console,output

Answer 2

のようなものです：

/* Hitting the count buffer first */ 
var source = Rx.Observable.interval(100) 
    .bufferWithTimeOrCount(500, 3) 
    .take(3); 

var subscription = source.subscribe(
    function (x) { 
     console.log('Next: ' + x.toString()); 
    }, 
    function (err) { 
     console.log('Error: ' + err); 
    }, 
    function() { 
     console.log('Completed'); 
    }); 

// => Next: 0,1,2 
// => Next: 3,4,5 
// => Next: 6,7,8 
// => Completed