| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177 |
- export { Observable, Subject } from 'rxjs';
- export { AnonymousSubject } from 'rxjs/internal-compatibility';
- export { config } from 'rxjs/internal-compatibility';
- import './add/observable/bindCallback';
- import './add/observable/bindNodeCallback';
- import './add/observable/combineLatest';
- import './add/observable/concat';
- import './add/observable/defer';
- import './add/observable/empty';
- import './add/observable/forkJoin';
- import './add/observable/from';
- import './add/observable/fromEvent';
- import './add/observable/fromEventPattern';
- import './add/observable/fromPromise';
- import './add/observable/generate';
- import './add/observable/if';
- import './add/observable/interval';
- import './add/observable/merge';
- import './add/observable/race';
- import './add/observable/never';
- import './add/observable/of';
- import './add/observable/onErrorResumeNext';
- import './add/observable/pairs';
- import './add/observable/range';
- import './add/observable/using';
- import './add/observable/throw';
- import './add/observable/timer';
- import './add/observable/zip';
- import './add/observable/dom/ajax';
- import './add/observable/dom/webSocket';
- import './add/operator/buffer';
- import './add/operator/bufferCount';
- import './add/operator/bufferTime';
- import './add/operator/bufferToggle';
- import './add/operator/bufferWhen';
- import './add/operator/catch';
- import './add/operator/combineAll';
- import './add/operator/combineLatest';
- import './add/operator/concat';
- import './add/operator/concatAll';
- import './add/operator/concatMap';
- import './add/operator/concatMapTo';
- import './add/operator/count';
- import './add/operator/dematerialize';
- import './add/operator/debounce';
- import './add/operator/debounceTime';
- import './add/operator/defaultIfEmpty';
- import './add/operator/delay';
- import './add/operator/delayWhen';
- import './add/operator/distinct';
- import './add/operator/distinctUntilChanged';
- import './add/operator/distinctUntilKeyChanged';
- import './add/operator/do';
- import './add/operator/exhaust';
- import './add/operator/exhaustMap';
- import './add/operator/expand';
- import './add/operator/elementAt';
- import './add/operator/filter';
- import './add/operator/finally';
- import './add/operator/find';
- import './add/operator/findIndex';
- import './add/operator/first';
- import './add/operator/groupBy';
- import './add/operator/ignoreElements';
- import './add/operator/isEmpty';
- import './add/operator/audit';
- import './add/operator/auditTime';
- import './add/operator/last';
- import './add/operator/let';
- import './add/operator/every';
- import './add/operator/map';
- import './add/operator/mapTo';
- import './add/operator/materialize';
- import './add/operator/max';
- import './add/operator/merge';
- import './add/operator/mergeAll';
- import './add/operator/mergeMap';
- import './add/operator/mergeMapTo';
- import './add/operator/mergeScan';
- import './add/operator/min';
- import './add/operator/multicast';
- import './add/operator/observeOn';
- import './add/operator/onErrorResumeNext';
- import './add/operator/pairwise';
- import './add/operator/partition';
- import './add/operator/pluck';
- import './add/operator/publish';
- import './add/operator/publishBehavior';
- import './add/operator/publishReplay';
- import './add/operator/publishLast';
- import './add/operator/race';
- import './add/operator/reduce';
- import './add/operator/repeat';
- import './add/operator/repeatWhen';
- import './add/operator/retry';
- import './add/operator/retryWhen';
- import './add/operator/sample';
- import './add/operator/sampleTime';
- import './add/operator/scan';
- import './add/operator/sequenceEqual';
- import './add/operator/share';
- import './add/operator/shareReplay';
- import './add/operator/single';
- import './add/operator/skip';
- import './add/operator/skipLast';
- import './add/operator/skipUntil';
- import './add/operator/skipWhile';
- import './add/operator/startWith';
- import './add/operator/subscribeOn';
- import './add/operator/switch';
- import './add/operator/switchMap';
- import './add/operator/switchMapTo';
- import './add/operator/take';
- import './add/operator/takeLast';
- import './add/operator/takeUntil';
- import './add/operator/takeWhile';
- import './add/operator/throttle';
- import './add/operator/throttleTime';
- import './add/operator/timeInterval';
- import './add/operator/timeout';
- import './add/operator/timeoutWith';
- import './add/operator/timestamp';
- import './add/operator/toArray';
- import './add/operator/toPromise';
- import './add/operator/window';
- import './add/operator/windowCount';
- import './add/operator/windowTime';
- import './add/operator/windowToggle';
- import './add/operator/windowWhen';
- import './add/operator/withLatestFrom';
- import './add/operator/zip';
- import './add/operator/zipAll';
- export { Observer, Subscription, ReplaySubject, BehaviorSubject, Notification, EmptyError, ArgumentOutOfRangeError, ObjectUnsubscribedError, UnsubscriptionError, pipe } from 'rxjs';
- export { TestScheduler } from 'rxjs/testing';
- export { Operator, Subscriber, AsyncSubject, ConnectableObservable, TimeoutError, VirtualTimeScheduler } from 'rxjs';
- export { AjaxRequest, AjaxResponse, AjaxError, AjaxTimeoutError } from 'rxjs/ajax';
- import { SchedulerLike } from 'rxjs';
- export { TimeInterval, Timestamp } from 'rxjs/internal-compatibility';
- import * as _operators from 'rxjs/operators';
- export declare const operators: typeof _operators;
- /**
- * @typedef {Object} Rx.Scheduler
- * @property {Scheduler} queue Schedules on a queue in the current event frame
- * (trampoline scheduler). Use this for iteration operations.
- * @property {Scheduler} asap Schedules on the micro task queue, which is the same
- * queue used for promises. Basically after the current job, but before the next
- * job. Use this for asynchronous conversions.
- * @property {Scheduler} async Schedules work with `setInterval`. Use this for
- * time-based operations.
- * @property {Scheduler} animationFrame Schedules work with `requestAnimationFrame`.
- * Use this for synchronizing with the platform's painting
- */
- declare let Scheduler: {
- asap: SchedulerLike;
- queue: SchedulerLike;
- animationFrame: SchedulerLike;
- async: SchedulerLike;
- };
- /**
- * @typedef {Object} Rx.Symbol
- * @property {Symbol|string} rxSubscriber A symbol to use as a property name to
- * retrieve an "Rx safe" Observer from an object. "Rx safety" can be defined as
- * an object that has all of the traits of an Rx Subscriber, including the
- * ability to add and remove subscriptions to the subscription chain and
- * guarantees involving event triggering (can't "next" after unsubscription,
- * etc).
- * @property {Symbol|string} observable A symbol to use as a property name to
- * retrieve an Observable as defined by the [ECMAScript "Observable" spec](https://github.com/zenparsing/es-observable).
- * @property {Symbol|string} iterator The ES6 symbol to use as a property name
- * to retrieve an iterator from an object.
- */
- declare let Symbol: {
- rxSubscriber: string | symbol;
- observable: string | symbol;
- iterator: symbol;
- };
- export { Scheduler, Symbol };
|