UNPKG

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