Rx.d.ts 8.9 KB

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