Server IP : 150.95.80.236 / Your IP : 3.144.107.215 Web Server : Apache System : Linux host-150-95-80-236 3.10.0-1160.105.1.el7.x86_64 #1 SMP Thu Dec 7 15:39:45 UTC 2023 x86_64 User : social-telecare ( 10000) PHP Version : 7.4.33 Disable Function : opcache_get_status MySQL : OFF | cURL : ON | WGET : OFF | Perl : OFF | Python : OFF | Sudo : OFF | Pkexec : OFF Directory : /var/www/vhosts/pcu.in.th/api-uat.pcu.in.th/node_modules/rxjs/dist/esm5/internal/testing/ |
Upload File : |
import { __extends } from "tslib"; import { Subject } from '../Subject'; import { Subscription } from '../Subscription'; import { SubscriptionLoggable } from './SubscriptionLoggable'; import { applyMixins } from '../util/applyMixins'; import { observeNotification } from '../Notification'; var HotObservable = (function (_super) { __extends(HotObservable, _super); function HotObservable(messages, scheduler) { var _this = _super.call(this) || this; _this.messages = messages; _this.subscriptions = []; _this.scheduler = scheduler; return _this; } HotObservable.prototype._subscribe = function (subscriber) { var subject = this; var index = subject.logSubscribedFrame(); var subscription = new Subscription(); subscription.add(new Subscription(function () { subject.logUnsubscribedFrame(index); })); subscription.add(_super.prototype._subscribe.call(this, subscriber)); return subscription; }; HotObservable.prototype.setup = function () { var subject = this; var messagesLength = subject.messages.length; var _loop_1 = function (i) { (function () { var _a = subject.messages[i], notification = _a.notification, frame = _a.frame; subject.scheduler.schedule(function () { observeNotification(notification, subject); }, frame); })(); }; for (var i = 0; i < messagesLength; i++) { _loop_1(i); } }; return HotObservable; }(Subject)); export { HotObservable }; applyMixins(HotObservable, [SubscriptionLoggable]); //# sourceMappingURL=HotObservable.js.map