File manager - Edit - /usr/local/lib/node_modules/ghost-cli/node_modules/listr/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts
Back
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 }); } }
| ver. 1.4 |
Github
|
.
| PHP 8.2.30 | Generation time: 0 |
proxy
|
phpinfo
|
Settings