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%2Fthrottle.js;h=259cf998f19e5df5210842f3e28857c9b0da306f;hp=4347483592e82d9b514f36e75ffee04fcd8fc090;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/throttle.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/throttle.js index 43474835..259cf998 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/throttle.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/throttle.js @@ -13,15 +13,14 @@ 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"); exports.defaultThrottleConfig = { leading: true, trailing: false }; function throttle(durationSelector, config) { if (config === void 0) { config = exports.defaultThrottleConfig; } - return function (source) { return source.lift(new ThrottleOperator(durationSelector, config.leading, config.trailing)); }; + return function (source) { return source.lift(new ThrottleOperator(durationSelector, !!config.leading, !!config.trailing)); }; } exports.throttle = throttle; var ThrottleOperator = (function () { @@ -65,12 +64,12 @@ var ThrottleSubscriber = (function (_super) { this.throttle(_sendValue); } this._hasValue = false; - this._sendValue = null; + this._sendValue = undefined; }; ThrottleSubscriber.prototype.throttle = function (value) { var duration = this.tryDurationSelector(value); if (!!duration) { - this.add(this._throttled = subscribeToResult_1.subscribeToResult(this, duration)); + this.add(this._throttled = innerSubscribe_1.innerSubscribe(duration, new innerSubscribe_1.SimpleInnerSubscriber(this))); } }; ThrottleSubscriber.prototype.tryDurationSelector = function (value) { @@ -87,17 +86,17 @@ var ThrottleSubscriber = (function (_super) { if (_throttled) { _throttled.unsubscribe(); } - this._throttled = null; + this._throttled = undefined; if (_trailing) { this.send(); } }; - ThrottleSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) { + ThrottleSubscriber.prototype.notifyNext = function () { this.throttlingDone(); }; ThrottleSubscriber.prototype.notifyComplete = function () { this.throttlingDone(); }; return ThrottleSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); //# sourceMappingURL=throttle.js.map \ No newline at end of file