import { Observable } from './Observable'

const interval = (timespan: number) =>
  new Observable(({ next }) => {
    let time = 0;
    setInterval(() => {
      next(time);
      time += timespan;
    }, timespan);
  });

interval(1000).subscribe(console.log)