subscribeToObservable.js 556 B

1234567891011121314
  1. /** PURE_IMPORTS_START _symbol_observable PURE_IMPORTS_END */
  2. import { observable as Symbol_observable } from '../symbol/observable';
  3. export var subscribeToObservable = function (obj) {
  4. return function (subscriber) {
  5. var obs = obj[Symbol_observable]();
  6. if (typeof obs.subscribe !== 'function') {
  7. throw new TypeError('Provided object does not correctly implement Symbol.observable');
  8. }
  9. else {
  10. return obs.subscribe(subscriber);
  11. }
  12. };
  13. };
  14. //# sourceMappingURL=subscribeToObservable.js.map