1e02f9b90303035cd427c6540a4ad9e94b95a9c43899f5ea3982dfd6a87441f4feb2b96aea93c3d3910904c97cb09f4e622520e12e4f332464f59d5557f384 579 B

12345678910111213141516
  1. import { SubscribeOnObservable } from '../observable/SubscribeOnObservable';
  2. export function subscribeOn(scheduler, delay = 0) {
  3. return function subscribeOnOperatorFunction(source) {
  4. return source.lift(new SubscribeOnOperator(scheduler, delay));
  5. };
  6. }
  7. class SubscribeOnOperator {
  8. constructor(scheduler, delay) {
  9. this.scheduler = scheduler;
  10. this.delay = delay;
  11. }
  12. call(subscriber, source) {
  13. return new SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber);
  14. }
  15. }
  16. //# sourceMappingURL=subscribeOn.js.map