Start and Stop the Observable counter

gistfile1.txt

import Rx from 'rxjs'
const Observable = Rx.Observable;


// App logic
const startButton = document.querySelector('#start');
const stopButton = document.querySelector('#stop');

const start$ = Observable.fromEvent(startButton, 'click');
const interval$ = Observable.interval(1000);
const stop$ = Observable.fromEvent(stopButton, 'click');
const intervalThatStops$ = interval$.takeUntil(stop$);

const data = {count:0};

start$
.switchMapTo(intervalThatStops$)
.startWith(data)
.scan((acc)=> {
  return {count: acc.count + 1}
 },{count: 0})
.subscribe(x => console.log(x))