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 Observable_1 = require('../Observable');
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 ColdObservable = (function (_super) {
    __extends(ColdObservable, _super);
    function ColdObservable(messages, scheduler) {
        _super.call(this, function (subscriber) {
            var observable = this;
            var index = observable.logSubscribedFrame();
            subscriber.add(new Subscription_1.Subscription(function () {
                observable.logUnsubscribedFrame(index);
            }));
            observable.scheduleMessages(subscriber);
            return subscriber;
        });
        this.messages = messages;
        this.subscriptions = [];
        this.scheduler = scheduler;
    }
    ColdObservable.prototype.scheduleMessages = function (subscriber) {
        var messagesLength = this.messages.length;
        for (var i = 0; i < messagesLength; i++) {
            var message = this.messages[i];
            subscriber.add(this.scheduler.schedule(function (_a) {
                var message = _a.message, subscriber = _a.subscriber;
                message.notification.observe(subscriber);
            }, message.frame, { message: message, subscriber: subscriber }));
        }
    };
    return ColdObservable;
}(Observable_1.Observable));
exports.ColdObservable = ColdObservable;
applyMixins_1.applyMixins(ColdObservable, [SubscriptionLoggable_1.SubscriptionLoggable]);
//# sourceMappingURL=ColdObservable.js.map