fix(fromPromise): fix type signature

ReactiveX · Oct 12, 2015 · 17415fa · 17415fa
1 parent fffb96c
commit 17415fa
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
@@ -140,7 +140,7 @@ export default class Observable<T> implements CoreOperators<T>  {
   static fromArray: <T>(array: T[], scheduler?: Scheduler) => Observable<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>) => Observable<T>;
+  static fromPromise: <T>(promise: Promise<T>, scheduler?: Scheduler) => Observable<T>;
   static interval: (interval: number) => Observable<number>;
   static merge: (...observables:any[]) => Observable<any>;
   static never: <T>() => Observable<T>;

diff --git a/src/observables/PromiseObservable.ts b/src/observables/PromiseObservable.ts
@@ -9,7 +9,7 @@ export default class PromiseObservable<T> extends Observable<T> {
   _isScalar: boolean = false;
   value: T;
 
-  static create<T>(promise: Promise<T>, scheduler: Scheduler = immediate) {
+  static create<T>(promise: Promise<T>, scheduler: Scheduler = immediate): Observable<T> {
     return new PromiseObservable(promise, scheduler);
   }