Running average with rxjs 5

Viewed 1390

I would like to observe rolling averages with rxjs ^5

Half-solution

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);
2 Answers
Related