Gecko [ unitednationsplay.com ]

Linux unitednationsplay.com 3.10.0-1160.45.1.el7.x86_64 #1 SMP Wed Oct 13 17:20:51 UTC 2021 x86_64
nginx/1.20.1
Server IP : 188.130.139.92 & Your IP : 3.15.10.50
Domains : Cant Read [ /etc/named.conf ]
User : web

Name	Size	Permission	Date
ColdObservable.ts	1.62 KB	-rw-rw-r--	2022-08-30 11:49
HotObservable.ts	1.61 KB	-rw-rw-r--	2022-08-30 11:49
SubscriptionLog.ts	159 B	-rw-rw-r--	2022-08-30 11:49
SubscriptionLoggable.ts	635 B	-rw-rw-r--	2022-08-30 11:49
TestMessage.ts	133 B	-rw-rw-r--	2022-08-30 11:49
TestScheduler.ts	8.42 KB	-rw-rw-r--	2022-08-30 11:49

Rename

import { Observable } from '../Observable';
import { Subscription } from '../Subscription';
import { Scheduler } from '../Scheduler';
import { TestMessage } from './TestMessage';
import { SubscriptionLog } from './SubscriptionLog';
import { SubscriptionLoggable } from './SubscriptionLoggable';
import { applyMixins } from '../util/applyMixins';
import { Subscriber } from '../Subscriber';

/**
 * We need this JSDoc comment for affecting ESDoc.
 * @ignore
 * @extends {Ignored}
 */
export class ColdObservable<T> extends Observable<T> implements SubscriptionLoggable {
  public subscriptions: SubscriptionLog[] = [];
  scheduler: Scheduler;
  logSubscribedFrame: () => number;
  logUnsubscribedFrame: (index: number) => void;

constructor(public messages: TestMessage[],
              scheduler: Scheduler) {
    super(function (this: ColdObservable<T>, subscriber: Subscriber<any>) {
      const observable: ColdObservable<T> = this;
      const index = observable.logSubscribedFrame();
      subscriber.add(new Subscription(() => {
        observable.logUnsubscribedFrame(index);
      }));
      observable.scheduleMessages(subscriber);
      return subscriber;
    });
    this.scheduler = scheduler;
  }

scheduleMessages(subscriber: Subscriber<any>) {
    const messagesLength = this.messages.length;
    for (let i = 0; i < messagesLength; i++) {
      const message = this.messages[i];
      subscriber.add(
        this.scheduler.schedule(({message, subscriber}) => { message.notification.observe(subscriber); },
          message.frame,
          {message, subscriber})
      );
    }
  }
}
applyMixins(ColdObservable, [SubscriptionLoggable]);