Rx.js 9.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200
  1. "use strict";
  2. Object.defineProperty(exports, "__esModule", { value: true });
  3. var Subject_1 = require("./Subject");
  4. exports.Subject = Subject_1.Subject;
  5. exports.AnonymousSubject = Subject_1.AnonymousSubject;
  6. var Observable_1 = require("./Observable");
  7. exports.Observable = Observable_1.Observable;
  8. var config_1 = require("./config");
  9. exports.config = config_1.config;
  10. require("rxjs-compat/add/observable/bindCallback");
  11. require("rxjs-compat/add/observable/bindNodeCallback");
  12. require("rxjs-compat/add/observable/combineLatest");
  13. require("rxjs-compat/add/observable/concat");
  14. require("rxjs-compat/add/observable/defer");
  15. require("rxjs-compat/add/observable/empty");
  16. require("rxjs-compat/add/observable/forkJoin");
  17. require("rxjs-compat/add/observable/from");
  18. require("rxjs-compat/add/observable/fromEvent");
  19. require("rxjs-compat/add/observable/fromEventPattern");
  20. require("rxjs-compat/add/observable/fromPromise");
  21. require("rxjs-compat/add/observable/generate");
  22. require("rxjs-compat/add/observable/if");
  23. require("rxjs-compat/add/observable/interval");
  24. require("rxjs-compat/add/observable/merge");
  25. require("rxjs-compat/add/observable/race");
  26. require("rxjs-compat/add/observable/never");
  27. require("rxjs-compat/add/observable/of");
  28. require("rxjs-compat/add/observable/onErrorResumeNext");
  29. require("rxjs-compat/add/observable/pairs");
  30. require("rxjs-compat/add/observable/range");
  31. require("rxjs-compat/add/observable/using");
  32. require("rxjs-compat/add/observable/throw");
  33. require("rxjs-compat/add/observable/timer");
  34. require("rxjs-compat/add/observable/zip");
  35. require("rxjs-compat/add/observable/dom/ajax");
  36. require("rxjs-compat/add/observable/dom/webSocket");
  37. require("rxjs-compat/add/operator/buffer");
  38. require("rxjs-compat/add/operator/bufferCount");
  39. require("rxjs-compat/add/operator/bufferTime");
  40. require("rxjs-compat/add/operator/bufferToggle");
  41. require("rxjs-compat/add/operator/bufferWhen");
  42. require("rxjs-compat/add/operator/catch");
  43. require("rxjs-compat/add/operator/combineAll");
  44. require("rxjs-compat/add/operator/combineLatest");
  45. require("rxjs-compat/add/operator/concat");
  46. require("rxjs-compat/add/operator/concatAll");
  47. require("rxjs-compat/add/operator/concatMap");
  48. require("rxjs-compat/add/operator/concatMapTo");
  49. require("rxjs-compat/add/operator/count");
  50. require("rxjs-compat/add/operator/dematerialize");
  51. require("rxjs-compat/add/operator/debounce");
  52. require("rxjs-compat/add/operator/debounceTime");
  53. require("rxjs-compat/add/operator/defaultIfEmpty");
  54. require("rxjs-compat/add/operator/delay");
  55. require("rxjs-compat/add/operator/delayWhen");
  56. require("rxjs-compat/add/operator/distinct");
  57. require("rxjs-compat/add/operator/distinctUntilChanged");
  58. require("rxjs-compat/add/operator/distinctUntilKeyChanged");
  59. require("rxjs-compat/add/operator/do");
  60. require("rxjs-compat/add/operator/exhaust");
  61. require("rxjs-compat/add/operator/exhaustMap");
  62. require("rxjs-compat/add/operator/expand");
  63. require("rxjs-compat/add/operator/elementAt");
  64. require("rxjs-compat/add/operator/filter");
  65. require("rxjs-compat/add/operator/finally");
  66. require("rxjs-compat/add/operator/find");
  67. require("rxjs-compat/add/operator/findIndex");
  68. require("rxjs-compat/add/operator/first");
  69. require("rxjs-compat/add/operator/groupBy");
  70. require("rxjs-compat/add/operator/ignoreElements");
  71. require("rxjs-compat/add/operator/isEmpty");
  72. require("rxjs-compat/add/operator/audit");
  73. require("rxjs-compat/add/operator/auditTime");
  74. require("rxjs-compat/add/operator/last");
  75. require("rxjs-compat/add/operator/let");
  76. require("rxjs-compat/add/operator/every");
  77. require("rxjs-compat/add/operator/map");
  78. require("rxjs-compat/add/operator/mapTo");
  79. require("rxjs-compat/add/operator/materialize");
  80. require("rxjs-compat/add/operator/max");
  81. require("rxjs-compat/add/operator/merge");
  82. require("rxjs-compat/add/operator/mergeAll");
  83. require("rxjs-compat/add/operator/mergeMap");
  84. require("rxjs-compat/add/operator/mergeMapTo");
  85. require("rxjs-compat/add/operator/mergeScan");
  86. require("rxjs-compat/add/operator/min");
  87. require("rxjs-compat/add/operator/multicast");
  88. require("rxjs-compat/add/operator/observeOn");
  89. require("rxjs-compat/add/operator/onErrorResumeNext");
  90. require("rxjs-compat/add/operator/pairwise");
  91. require("rxjs-compat/add/operator/partition");
  92. require("rxjs-compat/add/operator/pluck");
  93. require("rxjs-compat/add/operator/publish");
  94. require("rxjs-compat/add/operator/publishBehavior");
  95. require("rxjs-compat/add/operator/publishReplay");
  96. require("rxjs-compat/add/operator/publishLast");
  97. require("rxjs-compat/add/operator/race");
  98. require("rxjs-compat/add/operator/reduce");
  99. require("rxjs-compat/add/operator/repeat");
  100. require("rxjs-compat/add/operator/repeatWhen");
  101. require("rxjs-compat/add/operator/retry");
  102. require("rxjs-compat/add/operator/retryWhen");
  103. require("rxjs-compat/add/operator/sample");
  104. require("rxjs-compat/add/operator/sampleTime");
  105. require("rxjs-compat/add/operator/scan");
  106. require("rxjs-compat/add/operator/sequenceEqual");
  107. require("rxjs-compat/add/operator/share");
  108. require("rxjs-compat/add/operator/shareReplay");
  109. require("rxjs-compat/add/operator/single");
  110. require("rxjs-compat/add/operator/skip");
  111. require("rxjs-compat/add/operator/skipLast");
  112. require("rxjs-compat/add/operator/skipUntil");
  113. require("rxjs-compat/add/operator/skipWhile");
  114. require("rxjs-compat/add/operator/startWith");
  115. require("rxjs-compat/add/operator/subscribeOn");
  116. require("rxjs-compat/add/operator/switch");
  117. require("rxjs-compat/add/operator/switchMap");
  118. require("rxjs-compat/add/operator/switchMapTo");
  119. require("rxjs-compat/add/operator/take");
  120. require("rxjs-compat/add/operator/takeLast");
  121. require("rxjs-compat/add/operator/takeUntil");
  122. require("rxjs-compat/add/operator/takeWhile");
  123. require("rxjs-compat/add/operator/throttle");
  124. require("rxjs-compat/add/operator/throttleTime");
  125. require("rxjs-compat/add/operator/timeInterval");
  126. require("rxjs-compat/add/operator/timeout");
  127. require("rxjs-compat/add/operator/timeoutWith");
  128. require("rxjs-compat/add/operator/timestamp");
  129. require("rxjs-compat/add/operator/toArray");
  130. require("rxjs-compat/add/operator/toPromise");
  131. require("rxjs-compat/add/operator/window");
  132. require("rxjs-compat/add/operator/windowCount");
  133. require("rxjs-compat/add/operator/windowTime");
  134. require("rxjs-compat/add/operator/windowToggle");
  135. require("rxjs-compat/add/operator/windowWhen");
  136. require("rxjs-compat/add/operator/withLatestFrom");
  137. require("rxjs-compat/add/operator/zip");
  138. require("rxjs-compat/add/operator/zipAll");
  139. var Subscription_1 = require("./Subscription");
  140. exports.Subscription = Subscription_1.Subscription;
  141. var Subscriber_1 = require("./Subscriber");
  142. exports.Subscriber = Subscriber_1.Subscriber;
  143. var AsyncSubject_1 = require("./AsyncSubject");
  144. exports.AsyncSubject = AsyncSubject_1.AsyncSubject;
  145. var ReplaySubject_1 = require("./ReplaySubject");
  146. exports.ReplaySubject = ReplaySubject_1.ReplaySubject;
  147. var BehaviorSubject_1 = require("./BehaviorSubject");
  148. exports.BehaviorSubject = BehaviorSubject_1.BehaviorSubject;
  149. var ConnectableObservable_1 = require("./observable/ConnectableObservable");
  150. exports.ConnectableObservable = ConnectableObservable_1.ConnectableObservable;
  151. var Notification_1 = require("./Notification");
  152. exports.Notification = Notification_1.Notification;
  153. exports.NotificationKind = Notification_1.NotificationKind;
  154. var EmptyError_1 = require("./util/EmptyError");
  155. exports.EmptyError = EmptyError_1.EmptyError;
  156. var ArgumentOutOfRangeError_1 = require("./util/ArgumentOutOfRangeError");
  157. exports.ArgumentOutOfRangeError = ArgumentOutOfRangeError_1.ArgumentOutOfRangeError;
  158. var ObjectUnsubscribedError_1 = require("./util/ObjectUnsubscribedError");
  159. exports.ObjectUnsubscribedError = ObjectUnsubscribedError_1.ObjectUnsubscribedError;
  160. var TimeoutError_1 = require("./util/TimeoutError");
  161. exports.TimeoutError = TimeoutError_1.TimeoutError;
  162. var UnsubscriptionError_1 = require("./util/UnsubscriptionError");
  163. exports.UnsubscriptionError = UnsubscriptionError_1.UnsubscriptionError;
  164. var timeInterval_1 = require("./operators/timeInterval");
  165. exports.TimeInterval = timeInterval_1.TimeInterval;
  166. var timestamp_1 = require("./operators/timestamp");
  167. exports.Timestamp = timestamp_1.Timestamp;
  168. var TestScheduler_1 = require("./testing/TestScheduler");
  169. exports.TestScheduler = TestScheduler_1.TestScheduler;
  170. var VirtualTimeScheduler_1 = require("./scheduler/VirtualTimeScheduler");
  171. exports.VirtualTimeScheduler = VirtualTimeScheduler_1.VirtualTimeScheduler;
  172. var AjaxObservable_1 = require("./observable/dom/AjaxObservable");
  173. exports.AjaxResponse = AjaxObservable_1.AjaxResponse;
  174. exports.AjaxError = AjaxObservable_1.AjaxError;
  175. exports.AjaxTimeoutError = AjaxObservable_1.AjaxTimeoutError;
  176. var pipe_1 = require("./util/pipe");
  177. exports.pipe = pipe_1.pipe;
  178. var asap_1 = require("./scheduler/asap");
  179. var async_1 = require("./scheduler/async");
  180. var queue_1 = require("./scheduler/queue");
  181. var animationFrame_1 = require("./scheduler/animationFrame");
  182. var rxSubscriber_1 = require("./symbol/rxSubscriber");
  183. var iterator_1 = require("./symbol/iterator");
  184. var observable_1 = require("./symbol/observable");
  185. var _operators = require("./operators/index");
  186. exports.operators = _operators;
  187. var Scheduler = {
  188. asap: asap_1.asap,
  189. queue: queue_1.queue,
  190. animationFrame: animationFrame_1.animationFrame,
  191. async: async_1.async
  192. };
  193. exports.Scheduler = Scheduler;
  194. var Symbol = {
  195. rxSubscriber: rxSubscriber_1.rxSubscriber,
  196. observable: observable_1.observable,
  197. iterator: iterator_1.iterator
  198. };
  199. exports.Symbol = Symbol;
  200. //# sourceMappingURL=Rx.js.map