source: trip-planner-front/node_modules/rxjs/internal/observable/SubscribeOnObservable.js

Last change on this file was 6a3a178, checked in by Ema <ema_spirova@…>, 3 years ago

initial commit

  • Property mode set to 100644
File size: 2.4 KB
Line 
1"use strict";
2var __extends = (this && this.__extends) || (function () {
3 var extendStatics = function (d, b) {
4 extendStatics = Object.setPrototypeOf ||
5 ({ __proto__: [] } instanceof Array && function (d, b) { d.__proto__ = b; }) ||
6 function (d, b) { for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p]; };
7 return extendStatics(d, b);
8 }
9 return function (d, b) {
10 extendStatics(d, b);
11 function __() { this.constructor = d; }
12 d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
13 };
14})();
15Object.defineProperty(exports, "__esModule", { value: true });
16var Observable_1 = require("../Observable");
17var asap_1 = require("../scheduler/asap");
18var isNumeric_1 = require("../util/isNumeric");
19var SubscribeOnObservable = (function (_super) {
20 __extends(SubscribeOnObservable, _super);
21 function SubscribeOnObservable(source, delayTime, scheduler) {
22 if (delayTime === void 0) { delayTime = 0; }
23 if (scheduler === void 0) { scheduler = asap_1.asap; }
24 var _this = _super.call(this) || this;
25 _this.source = source;
26 _this.delayTime = delayTime;
27 _this.scheduler = scheduler;
28 if (!isNumeric_1.isNumeric(delayTime) || delayTime < 0) {
29 _this.delayTime = 0;
30 }
31 if (!scheduler || typeof scheduler.schedule !== 'function') {
32 _this.scheduler = asap_1.asap;
33 }
34 return _this;
35 }
36 SubscribeOnObservable.create = function (source, delay, scheduler) {
37 if (delay === void 0) { delay = 0; }
38 if (scheduler === void 0) { scheduler = asap_1.asap; }
39 return new SubscribeOnObservable(source, delay, scheduler);
40 };
41 SubscribeOnObservable.dispatch = function (arg) {
42 var source = arg.source, subscriber = arg.subscriber;
43 return this.add(source.subscribe(subscriber));
44 };
45 SubscribeOnObservable.prototype._subscribe = function (subscriber) {
46 var delay = this.delayTime;
47 var source = this.source;
48 var scheduler = this.scheduler;
49 return scheduler.schedule(SubscribeOnObservable.dispatch, delay, {
50 source: source, subscriber: subscriber
51 });
52 };
53 return SubscribeOnObservable;
54}(Observable_1.Observable));
55exports.SubscribeOnObservable = SubscribeOnObservable;
56//# sourceMappingURL=SubscribeOnObservable.js.map
Note: See TracBrowser for help on using the repository browser.