UNPKG

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