some deletions

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

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/groupBy.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/groupBy.js
deleted file mode 100644 (file)
index c60d49d..0000000
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/groupBy.js
+++ /dev/null
@@ -1,164 +0,0 @@
-import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { Observable } from '../Observable';
-import { Subject } from '../Subject';
-export function groupBy(keySelector, elementSelector, durationSelector, subjectSelector) {
-    return (source) => source.lift(new GroupByOperator(keySelector, elementSelector, durationSelector, subjectSelector));
-}
-class GroupByOperator {
-    constructor(keySelector, elementSelector, durationSelector, subjectSelector) {
-        this.keySelector = keySelector;
-        this.elementSelector = elementSelector;
-        this.durationSelector = durationSelector;
-        this.subjectSelector = subjectSelector;
-    }
-    call(subscriber, source) {
-        return source.subscribe(new GroupBySubscriber(subscriber, this.keySelector, this.elementSelector, this.durationSelector, this.subjectSelector));
-    }
-}
-class GroupBySubscriber extends Subscriber {
-    constructor(destination, keySelector, elementSelector, durationSelector, subjectSelector) {
-        super(destination);
-        this.keySelector = keySelector;
-        this.elementSelector = elementSelector;
-        this.durationSelector = durationSelector;
-        this.subjectSelector = subjectSelector;
-        this.groups = null;
-        this.attemptedToUnsubscribe = false;
-        this.count = 0;
-    }
-    _next(value) {
-        let key;
-        try {
-            key = this.keySelector(value);
-        }
-        catch (err) {
-            this.error(err);
-            return;
-        }
-        this._group(value, key);
-    }
-    _group(value, key) {
-        let groups = this.groups;
-        if (!groups) {
-            groups = this.groups = new Map();
-        }
-        let group = groups.get(key);
-        let element;
-        if (this.elementSelector) {
-            try {
-                element = this.elementSelector(value);
-            }
-            catch (err) {
-                this.error(err);
-            }
-        }
-        else {
-            element = value;
-        }
-        if (!group) {
-            group = (this.subjectSelector ? this.subjectSelector() : new Subject());
-            groups.set(key, group);
-            const groupedObservable = new GroupedObservable(key, group, this);
-            this.destination.next(groupedObservable);
-            if (this.durationSelector) {
-                let duration;
-                try {
-                    duration = this.durationSelector(new GroupedObservable(key, group));
-                }
-                catch (err) {
-                    this.error(err);
-                    return;
-                }
-                this.add(duration.subscribe(new GroupDurationSubscriber(key, group, this)));
-            }
-        }
-        if (!group.closed) {
-            group.next(element);
-        }
-    }
-    _error(err) {
-        const groups = this.groups;
-        if (groups) {
-            groups.forEach((group, key) => {
-                group.error(err);
-            });
-            groups.clear();
-        }
-        this.destination.error(err);
-    }
-    _complete() {
-        const groups = this.groups;
-        if (groups) {
-            groups.forEach((group, key) => {
-                group.complete();
-            });
-            groups.clear();
-        }
-        this.destination.complete();
-    }
-    removeGroup(key) {
-        this.groups.delete(key);
-    }
-    unsubscribe() {
-        if (!this.closed) {
-            this.attemptedToUnsubscribe = true;
-            if (this.count === 0) {
-                super.unsubscribe();
-            }
-        }
-    }
-}
-class GroupDurationSubscriber extends Subscriber {
-    constructor(key, group, parent) {
-        super(group);
-        this.key = key;
-        this.group = group;
-        this.parent = parent;
-    }
-    _next(value) {
-        this.complete();
-    }
-    _unsubscribe() {
-        const { parent, key } = this;
-        this.key = this.parent = null;
-        if (parent) {
-            parent.removeGroup(key);
-        }
-    }
-}
-export class GroupedObservable extends Observable {
-    constructor(key, groupSubject, refCountSubscription) {
-        super();
-        this.key = key;
-        this.groupSubject = groupSubject;
-        this.refCountSubscription = refCountSubscription;
-    }
-    _subscribe(subscriber) {
-        const subscription = new Subscription();
-        const { refCountSubscription, groupSubject } = this;
-        if (refCountSubscription && !refCountSubscription.closed) {
-            subscription.add(new InnerRefCountSubscription(refCountSubscription));
-        }
-        subscription.add(groupSubject.subscribe(subscriber));
-        return subscription;
-    }
-}
-class InnerRefCountSubscription extends Subscription {
-    constructor(parent) {
-        super();
-        this.parent = parent;
-        parent.count++;
-    }
-    unsubscribe() {
-        const parent = this.parent;
-        if (!parent.closed && !this.closed) {
-            super.unsubscribe();
-            parent.count -= 1;
-            if (parent.count === 0 && parent.attemptedToUnsubscribe) {
-                parent.unsubscribe();
-            }
-        }
-    }
-}
-//# sourceMappingURL=groupBy.js.map
\ No newline at end of file