57e6dde1d96029e5e21827aed8844f580bfd5069db8a3ca2d543dc13cf78b46ca327f1e9fe790cd47307d6b9ea6904076776b0bf6132ca843dfd2f1dae399a 437 B

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