1 import { Observable } from '../Observable';
2 import { Subscription } from '../Subscription';
3 export function scheduleArray(input, scheduler) {
4 return new Observable(subscriber => {
5 const sub = new Subscription();
7 sub.add(scheduler.schedule(function () {
8 if (i === input.length) {
12 subscriber.next(input[i++]);
13 if (!subscriber.closed) {
14 sub.add(this.schedule());
20 //# sourceMappingURL=scheduleArray.js.map