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

AsyncSubject.ts

import { Subject } from './Subject';
import { Subscriber } from './Subscriber';

/**
 * A variant of Subject that only emits a value when it completes. It will emit
 * its latest value to all its observers on completion.
 *
 * @class AsyncSubject<T>
 */
export class AsyncSubject<T> extends Subject<T> {
  private _value: T | null = null;
  private _hasValue = false;
  private _isComplete = false;

/** @internal */
  protected _checkFinalizedStatuses(subscriber: Subscriber<T>) {
    const { hasError, _hasValue, _value, thrownError, isStopped, _isComplete } = this;
    if (hasError) {
      subscriber.error(thrownError);
    } else if (isStopped || _isComplete) {
      _hasValue && subscriber.next(_value!);
      subscriber.complete();
    }
  }

next(value: T): void {
    if (!this.isStopped) {
      this._value = value;
      this._hasValue = true;
    }
  }

complete(): void {
    const { _hasValue, _value, _isComplete } = this;
    if (!_isComplete) {
      this._isComplete = true;
      _hasValue && super.next(_value!);
      super.complete();
    }
  }
}

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
ajax	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
observable	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
operators	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
scheduled	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
scheduler	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
symbol	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
testing	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
util	dir	-	fits-hosting.de_5pri7emmx1j/psacln	0755	2024-11-26 10:52:34
AnyCatcher.ts	text/plain	613 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
AsyncSubject.ts	text/x-java	1.05 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
BehaviorSubject.ts	text/x-java	912 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Notification.ts	text/x-java	10.8 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
NotificationFactories.ts	text/x-java	1.15 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Observable.ts	text/x-java	19.69 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Operator.ts	text/x-java	290 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
ReplaySubject.ts	text/x-java	4.69 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Scheduler.ts	text/x-java	2.46 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Subject.ts	text/x-java	5.43 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Subscriber.ts	text/x-java	8.82 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
Subscription.ts	text/x-java	7.43 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
config.ts	text/x-java	3.97 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
firstValueFrom.ts	text/x-java	2.55 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
lastValueFrom.ts	text/x-java	2.48 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
types.ts	text/x-java	11.44 KB	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34
umd.ts	text/x-java	598 B	fits-hosting.de_5pri7emmx1j/psacln	0644	2024-11-26 10:52:34

Team Anon Force

https://t.me/Professor6T9x