fix(interval): fix signature type

ReactiveX · Oct 12, 2015 · 9c238c0 · 9c238c0
1 parent 17415fa
commit 9c238c0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/src/Observable.ts b/src/Observable.ts
@@ -141,7 +141,7 @@ export default class Observable<T> implements CoreOperators<T>  {
   static fromEvent: <T>(element: any, eventName: string, selector: (...args:Array<any>) => T) => Observable<T>;
   static fromEventPattern: <T>(addHandler: (handler:Function)=>void, removeHandler: (handler:Function) => void, selector?: (...args:Array<any>) => T) => Observable<T>;
   static fromPromise: <T>(promise: Promise<T>, scheduler?: Scheduler) => Observable<T>;
-  static interval: (interval: number) => Observable<number>;
+  static interval: (interval: number, scheduler?: Scheduler) => Observable<number>;
   static merge: (...observables:any[]) => Observable<any>;
   static never: <T>() => Observable<T>;
   static of: <T>(...values: (T | Scheduler)[]) => Observable<T>;

diff --git a/src/observables/IntervalObservable.ts b/src/observables/IntervalObservable.ts
@@ -5,7 +5,7 @@ import nextTick from '../schedulers/nextTick';
 
 export default class IntervalObservable<T> extends Observable<T> {
 
-  static create(period: number = 0, scheduler: Scheduler = nextTick) {
+  static create(period: number = 0, scheduler: Scheduler = nextTick): Observable<number> {
     return new IntervalObservable(period, scheduler);
   }