diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts | 52 |
1 files changed, 0 insertions, 52 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts deleted file mode 100644 index d66e3b100d..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts +++ /dev/null @@ -1,52 +0,0 @@ -import { SchedulerLike, SchedulerAction } from '../types'; -import { Subscriber } from '../Subscriber'; -import { Subscription } from '../Subscription'; -import { Observable } from '../Observable'; -import { asap } from '../scheduler/asap'; -import { isNumeric } from '../util/isNumeric'; - -export interface DispatchArg<T> { - source: Observable<T>; - subscriber: Subscriber<T>; -} - -/** - * We need this JSDoc comment for affecting ESDoc. - * @extends {Ignored} - * @hide true - */ -export class SubscribeOnObservable<T> extends Observable<T> { - /** @nocollapse */ - static create<T>(source: Observable<T>, delay: number = 0, scheduler: SchedulerLike = asap): Observable<T> { - return new SubscribeOnObservable(source, delay, scheduler); - } - - /** @nocollapse */ - static dispatch<T>(this: SchedulerAction<T>, arg: DispatchArg<T>): Subscription { - const { source, subscriber } = arg; - return this.add(source.subscribe(subscriber)); - } - - constructor(public source: Observable<T>, - private delayTime: number = 0, - private scheduler: SchedulerLike = asap) { - super(); - if (!isNumeric(delayTime) || delayTime < 0) { - this.delayTime = 0; - } - if (!scheduler || typeof scheduler.schedule !== 'function') { - this.scheduler = asap; - } - } - - /** @deprecated This is an internal implementation detail, do not use. */ - _subscribe(subscriber: Subscriber<T>) { - const delay = this.delayTime; - const source = this.source; - const scheduler = this.scheduler; - - return scheduler.schedule<DispatchArg<any>>(SubscribeOnObservable.dispatch, delay, { - source, subscriber - }); - } -} |