some deletions

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/shareReplay.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/shareReplay.js
deleted file mode 100644 (file)
index bc17d96..0000000
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/shareReplay.js
+++ /dev/null
@@ -1,57 +0,0 @@
-import { ReplaySubject } from '../ReplaySubject';
-export function shareReplay(configOrBufferSize, windowTime, scheduler) {
-    let config;
-    if (configOrBufferSize && typeof configOrBufferSize === 'object') {
-        config = configOrBufferSize;
-    }
-    else {
-        config = {
-            bufferSize: configOrBufferSize,
-            windowTime,
-            refCount: false,
-            scheduler
-        };
-    }
-    return (source) => source.lift(shareReplayOperator(config));
-}
-function shareReplayOperator({ bufferSize = Number.POSITIVE_INFINITY, windowTime = Number.POSITIVE_INFINITY, refCount: useRefCount, scheduler }) {
-    let subject;
-    let refCount = 0;
-    let subscription;
-    let hasError = false;
-    let isComplete = false;
-    return function shareReplayOperation(source) {
-        refCount++;
-        let innerSub;
-        if (!subject || hasError) {
-            hasError = false;
-            subject = new ReplaySubject(bufferSize, windowTime, scheduler);
-            innerSub = subject.subscribe(this);
-            subscription = source.subscribe({
-                next(value) { subject.next(value); },
-                error(err) {
-                    hasError = true;
-                    subject.error(err);
-                },
-                complete() {
-                    isComplete = true;
-                    subscription = undefined;
-                    subject.complete();
-                },
-            });
-        }
-        else {
-            innerSub = subject.subscribe(this);
-        }
-        this.add(() => {
-            refCount--;
-            innerSub.unsubscribe();
-            if (subscription && !isComplete && useRefCount && refCount === 0) {
-                subscription.unsubscribe();
-                subscription = undefined;
-                subject = undefined;
-            }
-        });
-    };
-}
-//# sourceMappingURL=shareReplay.js.map
\ No newline at end of file