1 import { Subject } from '../Subject';
2 import { Subscription } from '../Subscription';
3 import { SubscriptionLoggable } from './SubscriptionLoggable';
4 import { applyMixins } from '../util/applyMixins';
5 export class HotObservable extends Subject {
6 constructor(messages, scheduler) {
8 this.messages = messages;
9 this.subscriptions = [];
10 this.scheduler = scheduler;
12 _subscribe(subscriber) {
14 const index = subject.logSubscribedFrame();
15 const subscription = new Subscription();
16 subscription.add(new Subscription(() => {
17 subject.logUnsubscribedFrame(index);
19 subscription.add(super._subscribe(subscriber));
24 const messagesLength = subject.messages.length;
25 for (var i = 0; i < messagesLength; i++) {
27 var message = subject.messages[i];
28 subject.scheduler.schedule(() => { message.notification.observe(subject); }, message.frame);
33 applyMixins(HotObservable, [SubscriptionLoggable]);
34 //# sourceMappingURL=HotObservable.js.map