Pufferung mit Zeit und benutzerdefinierten Ereignis

Question

Ich begann gestern mit rxjs. Ich möchte das folgende Verhalten erreichen:

Ich möchte, dass mein Puffer mit Zeit und benutzerdefinierten Ereignissen erstellt wird. Stellen Sie sich vor, alle 2000 ms wird mein Puffer erzeugt (wie Standard bufferWithTime Funktionsverhalten) und für ein spezielles Ereignis wird ein Puffer erzeugt und der Timer wird neu initialisiert. Hier

eine Prinzipdarstellung:

Inhalt des Puffers A: [1, 2], B: [3, 4, 5], C: [6, 7], D: [8, 9].

Zeitsegmente A, B, haben die gleiche Dauer, 2000 ms.

Das Zeitsegment C war kürzer, da das spezielle Ereignis 7 ausgelöst wurde und ein Puffer erzeugt wurde.

Wie kann ich das tun?

Answer 1

Können Sie das versuchen (jsfiddle)?

// Helper functions 
function randomDelay(bottom, top) { 
    return Math.floor(Math.random() * (1 + top - bottom)) + bottom; 
} 

// Simulation of random sequence 
var source$ = Rx.Observable 
    .range(1, 30) 
    .concatMap(function (x) { 
    return Rx.Observable.of(x).delay(randomDelay(10,500)); 
    }); 

var intervalBetween = 1000; // should be 2000ms in your case 
var dummyStart$ = Rx.Observable.return({}); 
var specialEvent$ = Rx.Observable.fromEvent(document, 'click'); 
var opening$ = dummyStart$.concat(specialEvent$).flatMapLatest(function(x){return Rx.Observable.timer(0, intervalBetween)}); 
var buffers$ = source$.buffer(opening$).skip(1); 

source$.subscribe(function(x){console.log('source', x)}) 

buffers$.subscribe(function(buffer){ 
    console.log('buffer', buffer); 
}); 

Die Idee hier ist die buffer Operator mit der Unterschrift Rx.Observable.prototype.window(windowBoundaries); zu verwenden. Das sollte Ihnen nicht überlappende Puffer geben, die synchron mit dem windowBoundaries Signal ausgesendet werden.

Es gibt einen kleinen Trick (dummyStart), um den Timer sofort mit einer falschen specialEvent zu starten. Das erzeugt einen leeren Puffer als ersten Wert, der durch skip(1) entfernt wird.