diff --git a/src/internal/observable/DeferObservable.ts b/src/internal/observable/DeferObservable.ts index 346cacd040..6aea133f92 100644 --- a/src/internal/observable/DeferObservable.ts +++ b/src/internal/observable/DeferObservable.ts @@ -1,4 +1,4 @@ -import { Observable, SubscribableOrPromise } from '../Observable'; +import { Observable, ObservableInput } from '../Observable'; import { Subscriber } from '../Subscriber'; import { Subscription } from '../Subscription'; @@ -47,7 +47,7 @@ export class DeferObservable extends Observable { * * @see {@link create} * - * @param {function(): SubscribableOrPromise} observableFactory The Observable + * @param {function(): ObservableInput} observableFactory The Observable * factory function to invoke for each Observer that subscribes to the output * Observable. May also return a Promise, which will be converted on the fly * to an Observable. @@ -57,11 +57,11 @@ export class DeferObservable extends Observable { * @name defer * @owner Observable */ - static create(observableFactory: () => SubscribableOrPromise | void): Observable { + static create(observableFactory: () => ObservableInput | void): Observable { return new DeferObservable(observableFactory); } - constructor(private observableFactory: () => SubscribableOrPromise | void) { + constructor(private observableFactory: () => ObservableInput | void) { super(); } @@ -72,7 +72,7 @@ export class DeferObservable extends Observable { class DeferSubscriber extends OuterSubscriber { constructor(destination: Subscriber, - private factory: () => SubscribableOrPromise | void) { + private factory: () => ObservableInput | void) { super(destination); this.tryDefer(); }