node_modules/rxjs/dist/esm5/internal/scheduled/scheduleArray.js


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18

import { Observable } from '../Observable';
export function scheduleArray(input, scheduler) {
    return new Observable(function (subscriber) {
        var i = 0;
        return scheduler.schedule(function () {
            if (i === input.length) {
                subscriber.complete();
            }
            else {
                subscriber.next(input[i++]);
                if (!subscriber.closed) {
                    this.schedule();
                }
            }
        });
    });
}
//# sourceMappingURL=scheduleArray.js.map