2 Object.defineProperty(exports, "__esModule", { value: true });
3 var Observable_1 = require("../Observable");
4 var Subscription_1 = require("../Subscription");
5 var iterator_1 = require("../symbol/iterator");
6 function scheduleIterable(input, scheduler) {
8 throw new Error('Iterable cannot be null');
10 return new Observable_1.Observable(function (subscriber) {
11 var sub = new Subscription_1.Subscription();
14 if (iterator && typeof iterator.return === 'function') {
18 sub.add(scheduler.schedule(function () {
19 iterator = input[iterator_1.iterator]();
20 sub.add(scheduler.schedule(function () {
21 if (subscriber.closed) {
27 var result = iterator.next();
32 subscriber.error(err);
36 subscriber.complete();
39 subscriber.next(value);
47 exports.scheduleIterable = scheduleIterable;
48 //# sourceMappingURL=scheduleIterable.js.map