Gecko [ unitednationsplay.com ]

Name	Size	Permission	Date
ColdObservable.d.ts	783 B	-rw-rw-r--	2022-08-30 11:49
ColdObservable.js	1.89 KB	-rw-rw-r--	2022-08-30 11:49
ColdObservable.js.map	2.97 KB	-rw-rw-r--	2022-08-30 11:49
HotObservable.d.ts	879 B	-rw-rw-r--	2022-08-30 11:49
HotObservable.js	1.88 KB	-rw-rw-r--	2022-08-30 11:49
HotObservable.js.map	2.95 KB	-rw-rw-r--	2022-08-30 11:49
SubscriptionLog.d.ts	171 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLog.js	436 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLog.js.map	521 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLoggable.d.ts	286 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLoggable.js	868 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLoggable.js.map	1.35 KB	-rw-rw-r--	2022-08-30 11:49
TestMessage.d.ts	137 B	-rw-rw-r--	2022-08-30 11:49
TestMessage.js	53 B	-rw-rw-r--	2022-08-30 11:49
TestMessage.js.map	285 B	-rw-rw-r--	2022-08-30 11:49
TestScheduler.d.ts	1.51 KB	-rw-rw-r--	2022-08-30 11:49
TestScheduler.js	9.9 KB	-rw-rw-r--	2022-08-30 11:49
TestScheduler.js.map	16.51 KB	-rw-rw-r--	2022-08-30 11:49

Rename

"use strict";
var __extends = (this && this.__extends) || function (d, b) {
    for (var p in b) if (b.hasOwnProperty(p)) d[p] = b[p];
    function __() { this.constructor = d; }
    d.prototype = b === null ? Object.create(b) : (__.prototype = b.prototype, new __());
};
var Subject_1 = require('../Subject');
var Subscription_1 = require('../Subscription');
var SubscriptionLoggable_1 = require('./SubscriptionLoggable');
var applyMixins_1 = require('../util/applyMixins');
/**
 * We need this JSDoc comment for affecting ESDoc.
 * @ignore
 * @extends {Ignored}
 */
var HotObservable = (function (_super) {
    __extends(HotObservable, _super);
    function HotObservable(messages, scheduler) {
        _super.call(this);
        this.messages = messages;
        this.subscriptions = [];
        this.scheduler = scheduler;
    }
    /** @deprecated internal use only */ HotObservable.prototype._subscribe = function (subscriber) {
        var subject = this;
        var index = subject.logSubscribedFrame();
        subscriber.add(new Subscription_1.Subscription(function () {
            subject.logUnsubscribedFrame(index);
        }));
        return _super.prototype._subscribe.call(this, subscriber);
    };
    HotObservable.prototype.setup = function () {
        var subject = this;
        var messagesLength = subject.messages.length;
        /* tslint:disable:no-var-keyword */
        for (var i = 0; i < messagesLength; i++) {
            (function () {
                var message = subject.messages[i];
                /* tslint:enable */
                subject.scheduler.schedule(function () { message.notification.observe(subject); }, message.frame);
            })();
        }
    };
    return HotObservable;
}(Subject_1.Subject));
exports.HotObservable = HotObservable;
applyMixins_1.applyMixins(HotObservable, [SubscriptionLoggable_1.SubscriptionLoggable]);
//# sourceMappingURL=HotObservable.js.map