fromIterable.js 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