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