some deletions

[dotfiles/.git] / .config / coc / extensions / node_modules / coc-prettier / node_modules / rxjs / _esm2015 / internal / operators / refCount.js

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/refCount.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/refCount.js
deleted file mode 100644 (file)
index 3de8d1e..0000000
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/refCount.js
+++ /dev/null
@@ -1,52 +0,0 @@
-import { Subscriber } from '../Subscriber';
-export function refCount() {
-    return function refCountOperatorFunction(source) {
-        return source.lift(new RefCountOperator(source));
-    };
-}
-class RefCountOperator {
-    constructor(connectable) {
-        this.connectable = connectable;
-    }
-    call(subscriber, source) {
-        const { connectable } = this;
-        connectable._refCount++;
-        const refCounter = new RefCountSubscriber(subscriber, connectable);
-        const subscription = source.subscribe(refCounter);
-        if (!refCounter.closed) {
-            refCounter.connection = connectable.connect();
-        }
-        return subscription;
-    }
-}
-class RefCountSubscriber extends Subscriber {
-    constructor(destination, connectable) {
-        super(destination);
-        this.connectable = connectable;
-    }
-    _unsubscribe() {
-        const { connectable } = this;
-        if (!connectable) {
-            this.connection = null;
-            return;
-        }
-        this.connectable = null;
-        const refCount = connectable._refCount;
-        if (refCount <= 0) {
-            this.connection = null;
-            return;
-        }
-        connectable._refCount = refCount - 1;
-        if (refCount > 1) {
-            this.connection = null;
-            return;
-        }
-        const { connection } = this;
-        const sharedConnection = connectable._connection;
-        this.connection = null;
-        if (sharedConnection && (!connection || sharedConnection === connection)) {
-            sharedConnection.unsubscribe();
-        }
-    }
-}
-//# sourceMappingURL=refCount.js.map
\ No newline at end of file