ꦫꦣꦺꦤ꧀ꦄꦤ꧀ꦠꦱꦺꦤ

PATH: usr / local / lib / node_modules / ghost-cli / node_modules / rxjs / _esm5 / internal / operators

/** PURE_IMPORTS_START tslib,_Subscriber,_Subscription,_Observable,_Subject PURE_IMPORTS_END */
import * as tslib_1 from "tslib";
import { Subscriber } from '../Subscriber';
import { Subscription } from '../Subscription';
import { Observable } from '../Observable';
import { Subject } from '../Subject';
export function groupBy(keySelector, elementSelector, durationSelector, subjectSelector) {
    return function (source) {
        return source.lift(new GroupByOperator(keySelector, elementSelector, durationSelector, subjectSelector));
    };
}
var GroupByOperator = /*@__PURE__*/ (function () {
    function GroupByOperator(keySelector, elementSelector, durationSelector, subjectSelector) {
        this.keySelector = keySelector;
        this.elementSelector = elementSelector;
        this.durationSelector = durationSelector;
        this.subjectSelector = subjectSelector;
    }
    GroupByOperator.prototype.call = function (subscriber, source) {
        return source.subscribe(new GroupBySubscriber(subscriber, this.keySelector, this.elementSelector, this.durationSelector, this.subjectSelector));
    };
    return GroupByOperator;
}());
var GroupBySubscriber = /*@__PURE__*/ (function (_super) {
    tslib_1.__extends(GroupBySubscriber, _super);
    function GroupBySubscriber(destination, keySelector, elementSelector, durationSelector, subjectSelector) {
        var _this = _super.call(this, destination) || this;
        _this.keySelector = keySelector;
        _this.elementSelector = elementSelector;
        _this.durationSelector = durationSelector;
        _this.subjectSelector = subjectSelector;
        _this.groups = null;
        _this.attemptedToUnsubscribe = false;
        _this.count = 0;
        return _this;
    }
    GroupBySubscriber.prototype._next = function (value) {
        var key;
        try {
            key = this.keySelector(value);
        }
        catch (err) {
            this.error(err);
            return;
        }
        this._group(value, key);
    };
    GroupBySubscriber.prototype._group = function (value, key) {
        var groups = this.groups;
        if (!groups) {
            groups = this.groups = new Map();
        }
        var group = groups.get(key);
        var 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);
            var groupedObservable = new GroupedObservable(key, group, this);
            this.destination.next(groupedObservable);
            if (this.durationSelector) {
                var duration = void 0;
                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);
        }
    };
    GroupBySubscriber.prototype._error = function (err) {
        var groups = this.groups;
        if (groups) {
            groups.forEach(function (group, key) {
                group.error(err);
            });
            groups.clear();
        }
        this.destination.error(err);
    };
    GroupBySubscriber.prototype._complete = function () {
        var groups = this.groups;
        if (groups) {
            groups.forEach(function (group, key) {
                group.complete();
            });
            groups.clear();
        }
        this.destination.complete();
    };
    GroupBySubscriber.prototype.removeGroup = function (key) {
        this.groups.delete(key);
    };
    GroupBySubscriber.prototype.unsubscribe = function () {
        if (!this.closed) {
            this.attemptedToUnsubscribe = true;
            if (this.count === 0) {
                _super.prototype.unsubscribe.call(this);
            }
        }
    };
    return GroupBySubscriber;
}(Subscriber));
var GroupDurationSubscriber = /*@__PURE__*/ (function (_super) {
    tslib_1.__extends(GroupDurationSubscriber, _super);
    function GroupDurationSubscriber(key, group, parent) {
        var _this = _super.call(this, group) || this;
        _this.key = key;
        _this.group = group;
        _this.parent = parent;
        return _this;
    }
    GroupDurationSubscriber.prototype._next = function (value) {
        this.complete();
    };
    GroupDurationSubscriber.prototype._unsubscribe = function () {
        var _a = this, parent = _a.parent, key = _a.key;
        this.key = this.parent = null;
        if (parent) {
            parent.removeGroup(key);
        }
    };
    return GroupDurationSubscriber;
}(Subscriber));
var GroupedObservable = /*@__PURE__*/ (function (_super) {
    tslib_1.__extends(GroupedObservable, _super);
    function GroupedObservable(key, groupSubject, refCountSubscription) {
        var _this = _super.call(this) || this;
        _this.key = key;
        _this.groupSubject = groupSubject;
        _this.refCountSubscription = refCountSubscription;
        return _this;
    }
    GroupedObservable.prototype._subscribe = function (subscriber) {
        var subscription = new Subscription();
        var _a = this, refCountSubscription = _a.refCountSubscription, groupSubject = _a.groupSubject;
        if (refCountSubscription && !refCountSubscription.closed) {
            subscription.add(new InnerRefCountSubscription(refCountSubscription));
        }
        subscription.add(groupSubject.subscribe(subscriber));
        return subscription;
    };
    return GroupedObservable;
}(Observable));
export { GroupedObservable };
var InnerRefCountSubscription = /*@__PURE__*/ (function (_super) {
    tslib_1.__extends(InnerRefCountSubscription, _super);
    function InnerRefCountSubscription(parent) {
        var _this = _super.call(this) || this;
        _this.parent = parent;
        parent.count++;
        return _this;
    }
    InnerRefCountSubscription.prototype.unsubscribe = function () {
        var parent = this.parent;
        if (!parent.closed && !this.closed) {
            _super.prototype.unsubscribe.call(this);
            parent.count -= 1;
            if (parent.count === 0 && parent.attemptedToUnsubscribe) {
                parent.unsubscribe();
            }
        }
    };
    return InnerRefCountSubscription;
}(Subscription));
//# sourceMappingURL=groupBy.js.map

[+] ..
[-] withLatestFrom.js [edit]
[-] skipLast.js.map [edit]
[-] publishReplay.js [edit]
[-] exhaust.js [edit]
[-] zip.js.map [edit]
[-] mergeAll.js.map [edit]
[-] single.js [edit]
[-] mergeMapTo.js.map [edit]
[-] distinctUntilChanged.js [edit]
[-] throttle.js [edit]
[-] find.js [edit]
[-] bufferToggle.js [edit]
[-] concat.js [edit]
[-] isEmpty.js.map [edit]
[-] windowTime.js.map [edit]
[-] takeWhile.js.map [edit]
[-] combineLatest.js [edit]
[-] debounce.js.map [edit]
[-] auditTime.js [edit]
[-] multicast.js.map [edit]
[-] dematerialize.js [edit]
[-] mapTo.js.map [edit]
[-] sample.js.map [edit]
[-] finalize.js [edit]
[-] takeUntil.js [edit]
[-] concatMap.js [edit]
[-] shareReplay.js.map [edit]
[-] zipAll.js [edit]
[-] windowToggle.js.map [edit]
[-] debounceTime.js [edit]
[-] sequenceEqual.js [edit]
[-] toArray.js [edit]
[-] pairwise.js.map [edit]
[-] index.js.map [edit]
[-] timestamp.js [edit]
[-] shareReplay.js [edit]
[-] mergeMap.js [edit]
[-] retryWhen.js [edit]
[-] bufferWhen.js.map [edit]
[-] reduce.js [edit]
[-] scan.js [edit]
[-] max.js [edit]
[-] mergeMapTo.js [edit]
[-] throttle.js.map [edit]
[-] skipWhile.js.map [edit]
[-] delay.js [edit]
[-] every.js.map [edit]
[-] concat.js.map [edit]
[-] refCount.js [edit]
[-] materialize.js [edit]
[-] publishLast.js.map [edit]
[-] windowCount.js.map [edit]
[-] toArray.js.map [edit]
[-] catchError.js [edit]
[-] buffer.js [edit]
[-] buffer.js.map [edit]
[-] observeOn.js.map [edit]
[-] elementAt.js.map [edit]
[-] skip.js.map [edit]
[-] exhaust.js.map [edit]
[-] concatMap.js.map [edit]
[-] mapTo.js [edit]
[-] repeatWhen.js.map [edit]
[-] pluck.js [edit]
[-] publish.js.map [edit]
[-] takeLast.js [edit]
[-] distinct.js.map [edit]
[-] subscribeOn.js.map [edit]
[-] groupBy.js.map [edit]
[-] merge.js.map [edit]
[-] first.js.map [edit]
[-] publishBehavior.js [edit]
[-] throttleTime.js [edit]
[-] skip.js [edit]
[-] debounce.js [edit]
[-] count.js.map [edit]
[-] retry.js [edit]
[-] timeout.js [edit]
[-] throwIfEmpty.js.map [edit]
[-] bufferTime.js.map [edit]
[-] concatAll.js.map [edit]
[-] takeUntil.js.map [edit]
[-] take.js [edit]
[-] pairwise.js [edit]
[-] skipUntil.js.map [edit]
[-] max.js.map [edit]
[-] take.js.map [edit]
[-] audit.js [edit]
[-] bufferWhen.js [edit]
[-] bufferCount.js.map [edit]
[-] reduce.js.map [edit]
[-] concatAll.js [edit]
[-] skipLast.js [edit]
[-] merge.js [edit]
[-] concatMapTo.js [edit]
[-] timeout.js.map [edit]
[-] defaultIfEmpty.js [edit]
[-] skipUntil.js [edit]
[-] mergeAll.js [edit]
[-] takeLast.js.map [edit]
[-] exhaustMap.js [edit]
[-] publishLast.js [edit]
[-] ignoreElements.js [edit]
[-] share.js.map [edit]
[-] timeInterval.js.map [edit]
[-] onErrorResumeNext.js [edit]
[-] single.js.map [edit]
[-] delayWhen.js [edit]
[-] switchAll.js.map [edit]
[-] min.js [edit]
[-] last.js.map [edit]
[-] distinctUntilChanged.js.map [edit]
[-] windowCount.js [edit]
[-] switchMapTo.js [edit]
[-] throwIfEmpty.js [edit]
[-] tap.js.map [edit]
[-] onErrorResumeNext.js.map [edit]
[-] partition.js [edit]
[-] subscribeOn.js [edit]
[-] mergeMap.js.map [edit]
[-] groupBy.js [edit]
[-] first.js [edit]
[-] windowWhen.js [edit]
[-] scan.js.map [edit]
[-] map.js.map [edit]
[-] min.js.map [edit]
[-] debounceTime.js.map [edit]
[-] retryWhen.js.map [edit]
[-] windowToggle.js [edit]
[-] windowWhen.js.map [edit]
[-] share.js [edit]
[-] catchError.js.map [edit]
[-] zipAll.js.map [edit]
[-] pluck.js.map [edit]
[-] repeatWhen.js [edit]
[-] filter.js.map [edit]
[-] count.js [edit]
[-] index.js [edit]
[-] materialize.js.map [edit]
[-] timeoutWith.js [edit]
[-] zip.js [edit]
[-] bufferCount.js [edit]
[-] expand.js.map [edit]
[-] startWith.js [edit]
[-] endWith.js.map [edit]
[-] endWith.js [edit]
[-] windowTime.js [edit]
[-] race.js [edit]
[-] window.js.map [edit]
[-] delayWhen.js.map [edit]
[-] delay.js.map [edit]
[-] switchMap.js.map [edit]
[-] combineAll.js.map [edit]
[-] sampleTime.js [edit]
[-] switchMap.js [edit]
[-] race.js.map [edit]
[-] tap.js [edit]
[-] switchAll.js [edit]
[-] ignoreElements.js.map [edit]
[-] audit.js.map [edit]
[-] dematerialize.js.map [edit]
[-] timestamp.js.map [edit]
[-] finalize.js.map [edit]
[-] last.js [edit]
[-] publishReplay.js.map [edit]
[-] find.js.map [edit]
[-] timeInterval.js [edit]
[-] refCount.js.map [edit]
[-] auditTime.js.map [edit]
[-] combineAll.js [edit]
[-] publishBehavior.js.map [edit]
[-] defaultIfEmpty.js.map [edit]
[-] observeOn.js [edit]
[-] publish.js [edit]
[-] mergeScan.js.map [edit]
[-] concatMapTo.js.map [edit]
[-] map.js [edit]
[-] distinctUntilKeyChanged.js [edit]
[-] findIndex.js [edit]
[-] filter.js [edit]
[-] every.js [edit]
[-] sampleTime.js.map [edit]
[-] sequenceEqual.js.map [edit]
[-] takeWhile.js [edit]
[-] mergeScan.js [edit]
[-] bufferToggle.js.map [edit]
[-] exhaustMap.js.map [edit]
[-] multicast.js [edit]
[-] findIndex.js.map [edit]
[-] isEmpty.js [edit]
[-] retry.js.map [edit]
[-] startWith.js.map [edit]
[-] distinctUntilKeyChanged.js.map [edit]
[-] distinct.js [edit]
[-] bufferTime.js [edit]
[-] withLatestFrom.js.map [edit]
[-] repeat.js [edit]
[-] combineLatest.js.map [edit]
[-] partition.js.map [edit]
[-] elementAt.js [edit]
[-] skipWhile.js [edit]
[-] repeat.js.map [edit]
[-] timeoutWith.js.map [edit]
[-] sample.js [edit]
[-] window.js [edit]
[-] expand.js [edit]
[-] switchMapTo.js.map [edit]
[-] throttleTime.js.map [edit]