.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/observable/SubscribeOnObservable.ts

   1 import { SchedulerLike, SchedulerAction } from '../types';
   2 import { Subscriber } from '../Subscriber';
   3 import { Subscription } from '../Subscription';
   4 import { Observable } from '../Observable';
   5 import { asap } from '../scheduler/asap';
   6 import { isNumeric } from '../util/isNumeric';
   7
   8 export interface DispatchArg<T> {
   9   source: Observable<T>;
  10   subscriber: Subscriber<T>;
  11 }
  12
  13 /**
  14  * We need this JSDoc comment for affecting ESDoc.
  15  * @extends {Ignored}
  16  * @hide true
  17  */
  18 export class SubscribeOnObservable<T> extends Observable<T> {
  19   /** @nocollapse */
  20   static create<T>(source: Observable<T>, delay: number = 0, scheduler: SchedulerLike = asap): Observable<T> {
  21     return new SubscribeOnObservable(source, delay, scheduler);
  22   }
  23
  24   /** @nocollapse */
  25   static dispatch<T>(this: SchedulerAction<T>, arg: DispatchArg<T>): Subscription {
  26     const { source, subscriber } = arg;
  27     return this.add(source.subscribe(subscriber));
  28   }
  29
  30   constructor(public source: Observable<T>,
  31               private delayTime: number = 0,
  32               private scheduler: SchedulerLike = asap) {
  33     super();
  34     if (!isNumeric(delayTime) || delayTime < 0) {
  35       this.delayTime = 0;
  36     }
  37     if (!scheduler || typeof scheduler.schedule !== 'function') {
  38       this.scheduler = asap;
  39     }
  40   }
  41
  42   /** @deprecated This is an internal implementation detail, do not use. */
  43   _subscribe(subscriber: Subscriber<T>) {
  44     const delay = this.delayTime;
  45     const source = this.source;
  46     const scheduler = this.scheduler;
  47
  48     return scheduler.schedule<DispatchArg<any>>(SubscribeOnObservable.dispatch, delay, {
  49       source, subscriber
  50     });
  51   }
  52 }