| import { Observable } from '../Observable'; | 
| import { async } from '../scheduler/async'; | 
| import { isNumeric } from '../util/isNumeric'; | 
| import { isScheduler } from '../util/isScheduler'; | 
| export function timer(dueTime = 0, periodOrScheduler, scheduler) { | 
|     let period = -1; | 
|     if (isNumeric(periodOrScheduler)) { | 
|         period = Number(periodOrScheduler) < 1 && 1 || Number(periodOrScheduler); | 
|     } | 
|     else if (isScheduler(periodOrScheduler)) { | 
|         scheduler = periodOrScheduler; | 
|     } | 
|     if (!isScheduler(scheduler)) { | 
|         scheduler = async; | 
|     } | 
|     return new Observable(subscriber => { | 
|         const due = isNumeric(dueTime) | 
|             ? dueTime | 
|             : (+dueTime - scheduler.now()); | 
|         return scheduler.schedule(dispatch, due, { | 
|             index: 0, period, subscriber | 
|         }); | 
|     }); | 
| } | 
| function dispatch(state) { | 
|     const { index, period, subscriber } = state; | 
|     subscriber.next(index); | 
|     if (subscriber.closed) { | 
|         return; | 
|     } | 
|     else if (period === -1) { | 
|         return subscriber.complete(); | 
|     } | 
|     state.index = index + 1; | 
|     this.schedule(state, period); | 
| } | 
| //# sourceMappingURL=timer.js.map |