JSFiddle - React, Tailwind, and code Playground

by KristjanLaane

HTML

<script src="https://cdnjs.cloudflare.com/ajax/libs/rxjs/5.4.0/Rx.js"></script>

JavaScript

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);
dataToAverage$.map(arr => "Data to average: " + arr)
  .subscribe(s => console.log(s));
movingAverage$.map(average => "Moving average: " + average.toFixed(2))
  .subscribe(s => console.log(s));