123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195 |
- export { Subject, AnonymousSubject } from './Subject';
- export { Observable } from './Observable';
- 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 { Operator } from './Operator';
- export { Observer } from './Observer';
- export { Subscription } from './Subscription';
- export { Subscriber } from './Subscriber';
- export { AsyncSubject } from './AsyncSubject';
- export { ReplaySubject } from './ReplaySubject';
- export { BehaviorSubject } from './BehaviorSubject';
- export { ConnectableObservable } from './observable/ConnectableObservable';
- export { Notification } from './Notification';
- export { EmptyError } from './util/EmptyError';
- export { ArgumentOutOfRangeError } from './util/ArgumentOutOfRangeError';
- export { ObjectUnsubscribedError } from './util/ObjectUnsubscribedError';
- export { TimeoutError } from './util/TimeoutError';
- export { UnsubscriptionError } from './util/UnsubscriptionError';
- export { TimeInterval } from './operator/timeInterval';
- export { Timestamp } from './operators/timestamp';
- export { TestScheduler } from './testing/TestScheduler';
- export { VirtualTimeScheduler } from './scheduler/VirtualTimeScheduler';
- export { AjaxRequest, AjaxResponse, AjaxError, AjaxTimeoutError } from './observable/dom/AjaxObservable';
- export { pipe } from './util/pipe';
- import { AsapScheduler } from './scheduler/AsapScheduler';
- import { AsyncScheduler } from './scheduler/AsyncScheduler';
- import { QueueScheduler } from './scheduler/QueueScheduler';
- import { AnimationFrameScheduler } from './scheduler/AnimationFrameScheduler';
- import * as _operators from './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 uses the
- * fastest transport mechanism available, either Node.js' `process.nextTick()`
- * or Web Worker MessageChannel or setTimeout or others. 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: AsapScheduler;
- queue: QueueScheduler;
- animationFrame: AnimationFrameScheduler;
- async: AsyncScheduler;
- };
- /**
- * @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: any;
- observable: any;
- iterator: any;
- };
- export { Scheduler, Symbol };
|