function countInterval(interval, times) {
  return Rx.Observable.create(function (observer) {
    var timerId = Rx.Observable.timer(0, interval)
      .subscribe(count => {
        if (count>=times) {
          console.log('')
          observer.onNext(true);
          // I believe this already cleans up internal
          // references to setTimeout but I am not sure
          observer.onCompleted();
        }
      });

    // creating a disposable
    return () => {
      console.log('dispose')
      timerId.dispose();
    }
  });