X-Git-Url: https://git.josue.xyz/?p=dotfiles%2F.git;a=blobdiff_plain;f=.config%2Fcoc%2Fextensions%2Fnode_modules%2Fcoc-prettier%2Fnode_modules%2Frxjs%2Finternal%2Foperators%2Faudit.js;h=2b85c508dffed6ff1eb60a816619084881737ab2;hp=e6e13ca4189556d69dafc6ffd92ce97981c35266;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/audit.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/audit.js index e6e13ca4..2b85c508 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/audit.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/audit.js @@ -13,8 +13,7 @@ var __extends = (this && this.__extends) || (function () { }; })(); Object.defineProperty(exports, "__esModule", { value: true }); -var OuterSubscriber_1 = require("../OuterSubscriber"); -var subscribeToResult_1 = require("../util/subscribeToResult"); +var innerSubscribe_1 = require("../innerSubscribe"); function audit(durationSelector) { return function auditOperatorFunction(source) { return source.lift(new AuditOperator(durationSelector)); @@ -50,7 +49,7 @@ var AuditSubscriber = (function (_super) { catch (err) { return this.destination.error(err); } - var innerSubscription = subscribeToResult_1.subscribeToResult(this, duration); + var innerSubscription = innerSubscribe_1.innerSubscribe(duration, new innerSubscribe_1.SimpleInnerSubscriber(this)); if (!innerSubscription || innerSubscription.closed) { this.clearThrottle(); } @@ -63,21 +62,21 @@ var AuditSubscriber = (function (_super) { var _a = this, value = _a.value, hasValue = _a.hasValue, throttled = _a.throttled; if (throttled) { this.remove(throttled); - this.throttled = null; + this.throttled = undefined; throttled.unsubscribe(); } if (hasValue) { - this.value = null; + this.value = undefined; this.hasValue = false; this.destination.next(value); } }; - AuditSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex) { + AuditSubscriber.prototype.notifyNext = function () { this.clearThrottle(); }; AuditSubscriber.prototype.notifyComplete = function () { this.clearThrottle(); }; return AuditSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); //# sourceMappingURL=audit.js.map \ No newline at end of file