Giant blob of minor changes
[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / internal / operators / subscribeOn.js
1 "use strict";
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));
8     };
9 }
10 exports.subscribeOn = subscribeOn;
11 var SubscribeOnOperator = (function () {
12     function SubscribeOnOperator(scheduler, delay) {
13         this.scheduler = scheduler;
14         this.delay = delay;
15     }
16     SubscribeOnOperator.prototype.call = function (subscriber, source) {
17         return new SubscribeOnObservable_1.SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber);
18     };
19     return SubscribeOnOperator;
20 }());
21 //# sourceMappingURL=subscribeOn.js.map