0a4821000407f74580d670e67ba4abe6f4c203a8148c346f965210b075b30a0ac4ca4584265fe008e2ddc8b6997fffc22f5a59fc0dcba3ca09b3d8a5018a39 626 B

1234567891011121314151617181920
  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();
  6. let i = 0;
  7. sub.add(scheduler.schedule(function () {
  8. if (i === input.length) {
  9. subscriber.complete();
  10. return;
  11. }
  12. subscriber.next(input[i++]);
  13. if (!subscriber.closed) {
  14. sub.add(this.schedule());
  15. }
  16. }));
  17. return sub;
  18. });
  19. }
  20. //# sourceMappingURL=scheduleArray.js.map