byp4a55 professor6T9

Linux server800.serverconfig.center 6.1.0-48-amd64 #1 SMP PREEMPT_DYNAMIC Debian 6.1.172-1 (2026-05-15) x86_64
Apache
195.242.103.230

ColdObservable.ts

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';
import { observeNotification } from '../Notification';

export class ColdObservable<T> extends Observable<T> implements SubscriptionLoggable {
  public subscriptions: SubscriptionLog[] = [];
  scheduler: Scheduler;
  // @ts-ignore: Property has no initializer and is not definitely assigned
  logSubscribedFrame: () => number;
  // @ts-ignore: Property has no initializer and is not definitely assigned
  logUnsubscribedFrame: (index: number) => void;

constructor(public messages: TestMessage[], scheduler: Scheduler) {
    super(function (this: Observable<T>, subscriber: Subscriber<any>) {
      const observable: ColdObservable<T> = this as any;
      const index = observable.logSubscribedFrame();
      const subscription = new Subscription();
      subscription.add(
        new Subscription(() => {
          observable.logUnsubscribedFrame(index);
        })
      );
      observable.scheduleMessages(subscriber);
      return subscription;
    });
    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(
          (state) => {
            const { message: { notification }, subscriber: destination } = state!;
            observeNotification(notification, destination);
          },
          message.frame,
          { message, subscriber }
        )
      );
    }
  }
}
applyMixins(ColdObservable, [SubscriptionLoggable]);

Name	Type	Size	Owner/Group	Permission	Last Modified	Actions
.	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
..	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
ColdObservable.ts	text/x-java	1.91 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
HotObservable.ts	text/x-java	1.8 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
SubscriptionLog.ts	text/plain	143 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
SubscriptionLoggable.ts	text/x-java	711 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
TestMessage.ts	text/x-java	168 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
TestScheduler.ts	text/x-java	24.73 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34

Team Anon Force

https://t.me/Professor6T9x