rxjs - 使用 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