1 /** PURE_IMPORTS_START _observable_SubscribeOnObservable PURE_IMPORTS_END */
2 import { SubscribeOnObservable } from '../observable/SubscribeOnObservable';
3 export function subscribeOn(scheduler, delay) {
4 if (delay === void 0) {
7 return function subscribeOnOperatorFunction(source) {
8 return source.lift(new SubscribeOnOperator(scheduler, delay));
11 var SubscribeOnOperator = /*@__PURE__*/ (function () {
12 function SubscribeOnOperator(scheduler, delay) {
13 this.scheduler = scheduler;
16 SubscribeOnOperator.prototype.call = function (subscriber, source) {
17 return new SubscribeOnObservable(source, this.delay, this.scheduler).subscribe(subscriber);
19 return SubscribeOnOperator;
21 //# sourceMappingURL=subscribeOn.js.map