2 Object.defineProperty(exports, "__esModule", { value: true });
3 var SubscribeOnObservable_1 = require("../observable/SubscribeOnObservable");
4 function subscribeOn(scheduler, delay) {
5 if (delay === void 0) { delay = 0; }
6 return function subscribeOnOperatorFunction(source) {
7 return source.lift(new SubscribeOnOperator(scheduler, delay));
10 exports.subscribeOn = subscribeOn;
11 var SubscribeOnOperator = (function () {
12 function SubscribeOnOperator(scheduler, delay) {
13 this.scheduler = scheduler;
16 SubscribeOnOperator.prototype.call = function (subscriber, source) {
17 return new SubscribeOnObservable_1.SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber);
19 return SubscribeOnOperator;
21 //# sourceMappingURL=subscribeOn.js.map