Wie macht man einen Gleitpuffer-Stream?

Question

den folgenden Code gegeben, wo ich bufferCount (nicht ganz das, was ich will) verwenden ...

var Rx = require('rxjs/Rx'); 
    var Observable = Rx.Observable; 
    var Subject = Rx.Subject; 

    var first = new Rx.Subject(); 

    var source = first.bufferCount(2).map(a => a.reduce((acc,x) => acc+x,0)); 

    var subscription = source.subscribe(console.log) 

    first.next(1) 
    first.next(2) 
    first.next(2) 
    first.next(3) 

I

3 
5 

bekommen, was ich

ist

3 
4 
5 

bekommen möchten

, so dass der Puffer die letzten 2 Elemente puffert.

Gibt es eine Möglichkeit, dies einfach zu tun?

Answer 1

Haben Sie versucht, bufferCount 's skip/startBufferEvery Parameter zu verwenden? Auf diese Weise können Sie überlappende Puffer generieren, die Sie dann beliebig reduzieren können. Auf diese Weise werden keine Werte ausgegeben, die Sie anschließend herausfiltern müssen. Wenn Sie speziell eine Puffergröße von 2 wünschen, können Sie pairwise anstelle von bufferCount verwenden.

Keith: - Der Code mit dieser Methode

var Rx = require('rxjs/Rx'); 
var Observable = Rx.Observable; 
var Subject = Rx.Subject; 

var first = new Rx.Subject(); 

var source = first.bufferCount(2,1).map(a => a.reduce((acc,x) => acc+x,0)); 

var subscription = source.subscribe(console.log) 

first.next(1) 
first.next(2) 
first.next(2) 
first.next(3) 

Answer 2

Verwenden Sie den Operator scan, um den Gleitpuffer zu halten und die Operation auszuführen. Zum Beispiel:

var source = first.scan((slidingBuffer, newInput) => { 
    return addTo(slidingBuffer, newInput) 
    }, []) 
    .map(processBuffer) 

mit den addTo und processBuffer Funktionen offensichtliche Bedeutung haben.