1 /** PURE_IMPORTS_START tslib,_Observable,_scheduler_asap,_util_isNumeric PURE_IMPORTS_END */
2 import * as tslib_1 from "tslib";
3 import { Observable } from '../Observable';
4 import { asap } from '../scheduler/asap';
5 import { isNumeric } from '../util/isNumeric';
6 var SubscribeOnObservable = /*@__PURE__*/ (function (_super) {
7 tslib_1.__extends(SubscribeOnObservable, _super);
8 function SubscribeOnObservable(source, delayTime, scheduler) {
9 if (delayTime === void 0) {
12 if (scheduler === void 0) {
15 var _this = _super.call(this) || this;
16 _this.source = source;
17 _this.delayTime = delayTime;
18 _this.scheduler = scheduler;
19 if (!isNumeric(delayTime) || delayTime < 0) {
22 if (!scheduler || typeof scheduler.schedule !== 'function') {
23 _this.scheduler = asap;
27 SubscribeOnObservable.create = function (source, delay, scheduler) {
28 if (delay === void 0) {
31 if (scheduler === void 0) {
34 return new SubscribeOnObservable(source, delay, scheduler);
36 SubscribeOnObservable.dispatch = function (arg) {
37 var source = arg.source, subscriber = arg.subscriber;
38 return this.add(source.subscribe(subscriber));
40 SubscribeOnObservable.prototype._subscribe = function (subscriber) {
41 var delay = this.delayTime;
42 var source = this.source;
43 var scheduler = this.scheduler;
44 return scheduler.schedule(SubscribeOnObservable.dispatch, delay, {
45 source: source, subscriber: subscriber
48 return SubscribeOnObservable;
50 export { SubscribeOnObservable };
51 //# sourceMappingURL=SubscribeOnObservable.js.map