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);
  }