rxjs 5的运行平均值

Question

我想观察rxjs ^ 5的滚动平均值

半解

const data$ = Rx.Observable.range(1, 9);
const dataToAverage$ = data$.bufferCount(4, 1);
const movingAverage$ = dataToAverage$.map(arr =>
                       arr.reduce((acc, cur) => acc + cur) / arr.length);

• 上面的代码工作正常，除了它平均的第一个数据数组是 1,2,3,4。
• 我怎么能平均1，并1,2与1,2,3呢？
• 在https://jsfiddle.net/KristjanLaane/kLskp71j/中播放

Answer 1

我会这样：

Observable.range(1, 9)
    .scan((acc, curr) => {
        acc.push(curr);

        if (acc.length > 4) {
            acc.shift();
        }
        return acc;
    }, [])
    .map(arr => arr.reduce((acc, current) => acc + current, 0) / arr.length)
    .subscribe(console.log);

在scan()刚刚收集最多4项和map()然后计算平均值。

1
1.5
2
2.5
3.5
4.5
5.5
6.5
7.5