aboutsummaryrefslogtreecommitdiffstats
path: root/node_modules/rxjs/dist/esm/internal/Subscription.js
diff options
context:
space:
mode:
authorPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
committerPinapelz <yukais@pinapelz.com>2025-06-29 11:49:28 -0700
commitd55b767039605256c736166a942a9138e3eacfd7 (patch)
tree947063b634c50d438a794325f13275e134aa5993 /node_modules/rxjs/dist/esm/internal/Subscription.js
parent864ce67d89c77d8ef9c3361f80d619853abcf91c (diff)
remove dev node_modules (oops)
Diffstat (limited to 'node_modules/rxjs/dist/esm/internal/Subscription.js')
-rw-r--r--node_modules/rxjs/dist/esm/internal/Subscription.js119
1 files changed, 0 insertions, 119 deletions
diff --git a/node_modules/rxjs/dist/esm/internal/Subscription.js b/node_modules/rxjs/dist/esm/internal/Subscription.js
deleted file mode 100644
index 69835fb..0000000
--- a/node_modules/rxjs/dist/esm/internal/Subscription.js
+++ /dev/null
@@ -1,119 +0,0 @@
-import { isFunction } from './util/isFunction';
-import { UnsubscriptionError } from './util/UnsubscriptionError';
-import { arrRemove } from './util/arrRemove';
-export class Subscription {
- constructor(initialTeardown) {
- this.initialTeardown = initialTeardown;
- this.closed = false;
- this._parentage = null;
- this._finalizers = null;
- }
- unsubscribe() {
- let errors;
- if (!this.closed) {
- this.closed = true;
- const { _parentage } = this;
- if (_parentage) {
- this._parentage = null;
- if (Array.isArray(_parentage)) {
- for (const parent of _parentage) {
- parent.remove(this);
- }
- }
- else {
- _parentage.remove(this);
- }
- }
- const { initialTeardown: initialFinalizer } = this;
- if (isFunction(initialFinalizer)) {
- try {
- initialFinalizer();
- }
- catch (e) {
- errors = e instanceof UnsubscriptionError ? e.errors : [e];
- }
- }
- const { _finalizers } = this;
- if (_finalizers) {
- this._finalizers = null;
- for (const finalizer of _finalizers) {
- try {
- execFinalizer(finalizer);
- }
- catch (err) {
- errors = errors !== null && errors !== void 0 ? errors : [];
- if (err instanceof UnsubscriptionError) {
- errors = [...errors, ...err.errors];
- }
- else {
- errors.push(err);
- }
- }
- }
- }
- if (errors) {
- throw new UnsubscriptionError(errors);
- }
- }
- }
- add(teardown) {
- var _a;
- if (teardown && teardown !== this) {
- if (this.closed) {
- execFinalizer(teardown);
- }
- else {
- if (teardown instanceof Subscription) {
- if (teardown.closed || teardown._hasParent(this)) {
- return;
- }
- teardown._addParent(this);
- }
- (this._finalizers = (_a = this._finalizers) !== null && _a !== void 0 ? _a : []).push(teardown);
- }
- }
- }
- _hasParent(parent) {
- const { _parentage } = this;
- return _parentage === parent || (Array.isArray(_parentage) && _parentage.includes(parent));
- }
- _addParent(parent) {
- const { _parentage } = this;
- this._parentage = Array.isArray(_parentage) ? (_parentage.push(parent), _parentage) : _parentage ? [_parentage, parent] : parent;
- }
- _removeParent(parent) {
- const { _parentage } = this;
- if (_parentage === parent) {
- this._parentage = null;
- }
- else if (Array.isArray(_parentage)) {
- arrRemove(_parentage, parent);
- }
- }
- remove(teardown) {
- const { _finalizers } = this;
- _finalizers && arrRemove(_finalizers, teardown);
- if (teardown instanceof Subscription) {
- teardown._removeParent(this);
- }
- }
-}
-Subscription.EMPTY = (() => {
- const empty = new Subscription();
- empty.closed = true;
- return empty;
-})();
-export const EMPTY_SUBSCRIPTION = Subscription.EMPTY;
-export function isSubscription(value) {
- return (value instanceof Subscription ||
- (value && 'closed' in value && isFunction(value.remove) && isFunction(value.add) && isFunction(value.unsubscribe)));
-}
-function execFinalizer(finalizer) {
- if (isFunction(finalizer)) {
- finalizer();
- }
- else {
- finalizer.unsubscribe();
- }
-}
-//# sourceMappingURL=Subscription.js.map \ No newline at end of file
send patches to the email below
yukais@pinapelz.com
include the subject [PATCH repo_name]
pinapelz.com
homepage