1 /** PURE_IMPORTS_START _Observable,_Subscription,_symbol_iterator PURE_IMPORTS_END */
2 import { Observable } from '../Observable';
3 import { Subscription } from '../Subscription';
4 import { iterator as Symbol_iterator } from '../symbol/iterator';
5 export function scheduleIterable(input, scheduler) {
7 throw new Error('Iterable cannot be null');
9 return new Observable(function (subscriber) {
10 var sub = new Subscription();
13 if (iterator && typeof iterator.return === 'function') {
17 sub.add(scheduler.schedule(function () {
18 iterator = input[Symbol_iterator]();
19 sub.add(scheduler.schedule(function () {
20 if (subscriber.closed) {
26 var result = iterator.next();
31 subscriber.error(err);
35 subscriber.complete();
38 subscriber.next(value);
46 //# sourceMappingURL=scheduleIterable.js.map