Home Manual Reference Source Test Repository
dark themelight theme

es6/Rx.js

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