ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / ghost-cli / node_modules / rxjs / src / internal / observable

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
    });
  }
}

[-] never.ts [edit]
[-] timer.ts [edit]
[-] range.ts [edit]
[-] using.ts [edit]
[-] SubscribeOnObservable.ts [edit]
[-] empty.ts [edit]
[-] of.ts [edit]
[+] dom
[+] ..
[-] partition.ts [edit]
[-] bindCallback.ts [edit]
[-] iif.ts [edit]
[-] combineLatest.ts [edit]
[-] fromArray.ts [edit]
[-] pairs.ts [edit]
[-] forkJoin.ts [edit]
[-] fromEventPattern.ts [edit]
[-] fromEvent.ts [edit]
[-] defer.ts [edit]
[-] concat.ts [edit]
[-] onErrorResumeNext.ts [edit]
[-] interval.ts [edit]
[-] from.ts [edit]
[-] merge.ts [edit]
[-] ConnectableObservable.ts [edit]
[-] fromObservable.ts [edit]
[-] fromPromise.ts [edit]
[-] generate.ts [edit]
[-] zip.ts [edit]
[-] bindNodeCallback.ts [edit]
[-] fromIterable.ts [edit]
[-] throwError.ts [edit]
[-] race.ts [edit]