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

   1 /* tslint:disable:no-unused-variable */
   2 // Subject imported before Observable to bypass circular dependency issue since
   3 // Subject extends Observable and Observable references Subject in it's
   4 // definition
   5 export {Subject, AnonymousSubject} from './Subject';
   6 /* tslint:enable:no-unused-variable */
   7 export {Observable} from './Observable';
   8
   9 export { config } from './config';
  10
  11 // statics
  12 /* tslint:disable:no-use-before-declare */
  13 import 'rxjs-compat/add/observable/bindCallback';
  14 import 'rxjs-compat/add/observable/bindNodeCallback';
  15 import 'rxjs-compat/add/observable/combineLatest';
  16 import 'rxjs-compat/add/observable/concat';
  17 import 'rxjs-compat/add/observable/defer';
  18 import 'rxjs-compat/add/observable/empty';
  19 import 'rxjs-compat/add/observable/forkJoin';
  20 import 'rxjs-compat/add/observable/from';
  21 import 'rxjs-compat/add/observable/fromEvent';
  22 import 'rxjs-compat/add/observable/fromEventPattern';
  23 import 'rxjs-compat/add/observable/fromPromise';
  24 import 'rxjs-compat/add/observable/generate';
  25 import 'rxjs-compat/add/observable/if';
  26 import 'rxjs-compat/add/observable/interval';
  27 import 'rxjs-compat/add/observable/merge';
  28 import 'rxjs-compat/add/observable/race';
  29 import 'rxjs-compat/add/observable/never';
  30 import 'rxjs-compat/add/observable/of';
  31 import 'rxjs-compat/add/observable/onErrorResumeNext';
  32 import 'rxjs-compat/add/observable/pairs';
  33 import 'rxjs-compat/add/observable/range';
  34 import 'rxjs-compat/add/observable/using';
  35 import 'rxjs-compat/add/observable/throw';
  36 import 'rxjs-compat/add/observable/timer';
  37 import 'rxjs-compat/add/observable/zip';
  38
  39 //dom
  40 import 'rxjs-compat/add/observable/dom/ajax';
  41 import 'rxjs-compat/add/observable/dom/webSocket';
  42
  43 //internal/operators
  44 import 'rxjs-compat/add/operator/buffer';
  45 import 'rxjs-compat/add/operator/bufferCount';
  46 import 'rxjs-compat/add/operator/bufferTime';
  47 import 'rxjs-compat/add/operator/bufferToggle';
  48 import 'rxjs-compat/add/operator/bufferWhen';
  49 import 'rxjs-compat/add/operator/catch';
  50 import 'rxjs-compat/add/operator/combineAll';
  51 import 'rxjs-compat/add/operator/combineLatest';
  52 import 'rxjs-compat/add/operator/concat';
  53 import 'rxjs-compat/add/operator/concatAll';
  54 import 'rxjs-compat/add/operator/concatMap';
  55 import 'rxjs-compat/add/operator/concatMapTo';
  56 import 'rxjs-compat/add/operator/count';
  57 import 'rxjs-compat/add/operator/dematerialize';
  58 import 'rxjs-compat/add/operator/debounce';
  59 import 'rxjs-compat/add/operator/debounceTime';
  60 import 'rxjs-compat/add/operator/defaultIfEmpty';
  61 import 'rxjs-compat/add/operator/delay';
  62 import 'rxjs-compat/add/operator/delayWhen';
  63 import 'rxjs-compat/add/operator/distinct';
  64 import 'rxjs-compat/add/operator/distinctUntilChanged';
  65 import 'rxjs-compat/add/operator/distinctUntilKeyChanged';
  66 import 'rxjs-compat/add/operator/do';
  67 import 'rxjs-compat/add/operator/exhaust';
  68 import 'rxjs-compat/add/operator/exhaustMap';
  69 import 'rxjs-compat/add/operator/expand';
  70 import 'rxjs-compat/add/operator/elementAt';
  71 import 'rxjs-compat/add/operator/filter';
  72 import 'rxjs-compat/add/operator/finally';
  73 import 'rxjs-compat/add/operator/find';
  74 import 'rxjs-compat/add/operator/findIndex';
  75 import 'rxjs-compat/add/operator/first';
  76 import 'rxjs-compat/add/operator/groupBy';
  77 import 'rxjs-compat/add/operator/ignoreElements';
  78 import 'rxjs-compat/add/operator/isEmpty';
  79 import 'rxjs-compat/add/operator/audit';
  80 import 'rxjs-compat/add/operator/auditTime';
  81 import 'rxjs-compat/add/operator/last';
  82 import 'rxjs-compat/add/operator/let';
  83 import 'rxjs-compat/add/operator/every';
  84 import 'rxjs-compat/add/operator/map';
  85 import 'rxjs-compat/add/operator/mapTo';
  86 import 'rxjs-compat/add/operator/materialize';
  87 import 'rxjs-compat/add/operator/max';
  88 import 'rxjs-compat/add/operator/merge';
  89 import 'rxjs-compat/add/operator/mergeAll';
  90 import 'rxjs-compat/add/operator/mergeMap';
  91 import 'rxjs-compat/add/operator/mergeMapTo';
  92 import 'rxjs-compat/add/operator/mergeScan';
  93 import 'rxjs-compat/add/operator/min';
  94 import 'rxjs-compat/add/operator/multicast';
  95 import 'rxjs-compat/add/operator/observeOn';
  96 import 'rxjs-compat/add/operator/onErrorResumeNext';
  97 import 'rxjs-compat/add/operator/pairwise';
  98 import 'rxjs-compat/add/operator/partition';
  99 import 'rxjs-compat/add/operator/pluck';
 100 import 'rxjs-compat/add/operator/publish';
 101 import 'rxjs-compat/add/operator/publishBehavior';
 102 import 'rxjs-compat/add/operator/publishReplay';
 103 import 'rxjs-compat/add/operator/publishLast';
 104 import 'rxjs-compat/add/operator/race';
 105 import 'rxjs-compat/add/operator/reduce';
 106 import 'rxjs-compat/add/operator/repeat';
 107 import 'rxjs-compat/add/operator/repeatWhen';
 108 import 'rxjs-compat/add/operator/retry';
 109 import 'rxjs-compat/add/operator/retryWhen';
 110 import 'rxjs-compat/add/operator/sample';
 111 import 'rxjs-compat/add/operator/sampleTime';
 112 import 'rxjs-compat/add/operator/scan';
 113 import 'rxjs-compat/add/operator/sequenceEqual';
 114 import 'rxjs-compat/add/operator/share';
 115 import 'rxjs-compat/add/operator/shareReplay';
 116 import 'rxjs-compat/add/operator/single';
 117 import 'rxjs-compat/add/operator/skip';
 118 import 'rxjs-compat/add/operator/skipLast';
 119 import 'rxjs-compat/add/operator/skipUntil';
 120 import 'rxjs-compat/add/operator/skipWhile';
 121 import 'rxjs-compat/add/operator/startWith';
 122 import 'rxjs-compat/add/operator/subscribeOn';
 123 import 'rxjs-compat/add/operator/switch';
 124 import 'rxjs-compat/add/operator/switchMap';
 125 import 'rxjs-compat/add/operator/switchMapTo';
 126 import 'rxjs-compat/add/operator/take';
 127 import 'rxjs-compat/add/operator/takeLast';
 128 import 'rxjs-compat/add/operator/takeUntil';
 129 import 'rxjs-compat/add/operator/takeWhile';
 130 import 'rxjs-compat/add/operator/throttle';
 131 import 'rxjs-compat/add/operator/throttleTime';
 132 import 'rxjs-compat/add/operator/timeInterval';
 133 import 'rxjs-compat/add/operator/timeout';
 134 import 'rxjs-compat/add/operator/timeoutWith';
 135 import 'rxjs-compat/add/operator/timestamp';
 136 import 'rxjs-compat/add/operator/toArray';
 137 import 'rxjs-compat/add/operator/toPromise';
 138 import 'rxjs-compat/add/operator/window';
 139 import 'rxjs-compat/add/operator/windowCount';
 140 import 'rxjs-compat/add/operator/windowTime';
 141 import 'rxjs-compat/add/operator/windowToggle';
 142 import 'rxjs-compat/add/operator/windowWhen';
 143 import 'rxjs-compat/add/operator/withLatestFrom';
 144 import 'rxjs-compat/add/operator/zip';
 145 import 'rxjs-compat/add/operator/zipAll';
 146
 147 /* tslint:disable:no-unused-variable */
 148 export {Operator} from './Operator';
 149 export {Observer} from './types';
 150 export {Subscription} from './Subscription';
 151 export {Subscriber} from './Subscriber';
 152 export {AsyncSubject} from './AsyncSubject';
 153 export {ReplaySubject} from './ReplaySubject';
 154 export {BehaviorSubject} from './BehaviorSubject';
 155 export {ConnectableObservable} from './observable/ConnectableObservable';
 156 export {Notification, NotificationKind} from './Notification';
 157 export {EmptyError} from './util/EmptyError';
 158 export {ArgumentOutOfRangeError} from './util/ArgumentOutOfRangeError';
 159 export {ObjectUnsubscribedError} from './util/ObjectUnsubscribedError';
 160 export {TimeoutError} from './util/TimeoutError';
 161 export {UnsubscriptionError} from './util/UnsubscriptionError';
 162 export {TimeInterval} from './operators/timeInterval';
 163 export {Timestamp} from './operators/timestamp';
 164 export {TestScheduler} from './testing/TestScheduler';
 165 export {VirtualTimeScheduler} from './scheduler/VirtualTimeScheduler';
 166 export {AjaxRequest, AjaxResponse, AjaxError, AjaxTimeoutError} from './observable/dom/AjaxObservable';
 167 export { pipe } from './util/pipe';
 168
 169 import { asap } from './scheduler/asap';
 170 import { async } from './scheduler/async';
 171 import { queue } from './scheduler/queue';
 172 import { animationFrame } from './scheduler/animationFrame';
 173 import { AsapScheduler } from './scheduler/AsapScheduler';
 174 import { AsyncScheduler } from './scheduler/AsyncScheduler';
 175 import { QueueScheduler } from './scheduler/QueueScheduler';
 176 import { AnimationFrameScheduler } from './scheduler/AnimationFrameScheduler';
 177 import { rxSubscriber } from './symbol/rxSubscriber';
 178 import { iterator } from './symbol/iterator';
 179 import { observable } from './symbol/observable';
 180
 181 import * as _operators from './operators/index';
 182
 183 export const operators = _operators;
 184
 185 /* tslint:enable:no-unused-variable */
 186
 187 /**
 188  * @typedef {Object} Rx.Scheduler
 189  * @property {SchedulerLike} asap Schedules on the micro task queue, which is the same
 190  * queue used for promises. Basically after the current job, but before the next job.
 191  * Use this for asynchronous conversions.
 192  * @property {SchedulerLike} queue Schedules on a queue in the current event frame
 193  * (trampoline scheduler). Use this for iteration operations.
 194  * @property {SchedulerLike} animationFrame Schedules work with `requestAnimationFrame`.
 195  * Use this for synchronizing with the platform's painting.
 196  * @property {SchedulerLike} async Schedules work with `setInterval`. Use this for
 197  * time-based operations.
 198  */
 199 let Scheduler = {
 200   asap,
 201   queue,
 202   animationFrame,
 203   async
 204 };
 205
 206 /**
 207  * @typedef {Object} Rx.Symbol
 208  * @property {Symbol|string} rxSubscriber A symbol to use as a property name to
 209  * retrieve an "Rx safe" Observer from an object. "Rx safety" can be defined as
 210  * an object that has all of the traits of an Rx Subscriber, including the
 211  * ability to add and remove subscriptions to the subscription chain and
 212  * guarantees involving event triggering (can't "next" after unsubscription,
 213  * etc).
 214  * @property {Symbol|string} observable A symbol to use as a property name to
 215  * retrieve an Observable as defined by the [ECMAScript "Observable" spec](https://github.com/zenparsing/es-observable).
 216  * @property {Symbol|string} iterator The ES6 symbol to use as a property name
 217  * to retrieve an iterator from an object.
 218  */
 219 let Symbol = {
 220   rxSubscriber,
 221   observable,
 222   iterator
 223 };
 224
 225 export {
 226     Scheduler,
 227     Symbol
 228 };