Skip to content

Commit 17415fa

Browse files
luisgabrielbenlesh
authored andcommitted
fix(fromPromise): fix type signature
1 parent fffb96c commit 17415fa

File tree

2 files changed

+2
-2
lines changed

2 files changed

+2
-2
lines changed

src/Observable.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -140,7 +140,7 @@ export default class Observable<T> implements CoreOperators<T> {
140140
static fromArray: <T>(array: T[], scheduler?: Scheduler) => Observable<T>;
141141
static fromEvent: <T>(element: any, eventName: string, selector: (...args:Array<any>) => T) => Observable<T>;
142142
static fromEventPattern: <T>(addHandler: (handler:Function)=>void, removeHandler: (handler:Function) => void, selector?: (...args:Array<any>) => T) => Observable<T>;
143-
static fromPromise: <T>(promise: Promise<T>) => Observable<T>;
143+
static fromPromise: <T>(promise: Promise<T>, scheduler?: Scheduler) => Observable<T>;
144144
static interval: (interval: number) => Observable<number>;
145145
static merge: (...observables:any[]) => Observable<any>;
146146
static never: <T>() => Observable<T>;

src/observables/PromiseObservable.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -9,7 +9,7 @@ export default class PromiseObservable<T> extends Observable<T> {
99
_isScalar: boolean = false;
1010
value: T;
1111

12-
static create<T>(promise: Promise<T>, scheduler: Scheduler = immediate) {
12+
static create<T>(promise: Promise<T>, scheduler: Scheduler = immediate): Observable<T> {
1313
return new PromiseObservable(promise, scheduler);
1414
}
1515

0 commit comments

Comments
 (0)