bb83590475677335579e17e4671a295193b15ff141ea3aaa91a2961ecba1be599b0b5577c94dae94cfacdf92de00c2f55bf8afa37d6ba54a1328d92b1872f8 609 B

12345678910111213141516
  1. /** PURE_IMPORTS_START _Observable,_util_subscribeToIterable,_scheduled_scheduleIterable PURE_IMPORTS_END */
  2. import { Observable } from '../Observable';
  3. import { subscribeToIterable } from '../util/subscribeToIterable';
  4. import { scheduleIterable } from '../scheduled/scheduleIterable';
  5. export function fromIterable(input, scheduler) {
  6. if (!input) {
  7. throw new Error('Iterable cannot be null');
  8. }
  9. if (!scheduler) {
  10. return new Observable(subscribeToIterable(input));
  11. }
  12. else {
  13. return scheduleIterable(input, scheduler);
  14. }
  15. }
  16. //# sourceMappingURL=fromIterable.js.map