From e4fa1e69e7ebfb627c7198fd1a9881e9327ec4d4 Mon Sep 17 00:00:00 2001
From: Pinapelz <yukais@pinapelz.com>
Date: Sat, 28 Jun 2025 17:26:46 -0700
Subject: initial commit: scaffolding

---
 node_modules/rxjs/src/internal/AsyncSubject.ts | 39 ++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)
 create mode 100644 node_modules/rxjs/src/internal/AsyncSubject.ts

(limited to 'node_modules/rxjs/src/internal/AsyncSubject.ts')

diff --git a/node_modules/rxjs/src/internal/AsyncSubject.ts b/node_modules/rxjs/src/internal/AsyncSubject.ts
new file mode 100644
index 0000000..abb086c
--- /dev/null
+++ b/node_modules/rxjs/src/internal/AsyncSubject.ts
@@ -0,0 +1,39 @@
+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.
+ */
+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();
+    }
+  }
+}
-- 
cgit v1.2.3