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%2Fdistinct.js;h=1fd507adc83b3c6e96da3d25711d88178de0f2a0;hp=f9c7d8483119793761b442f3a590e3e01ad30f1d;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/distinct.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/distinct.js index f9c7d848..1fd507ad 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/distinct.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/internal/operators/distinct.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 distinct(keySelector, flushes) { return function (source) { return source.lift(new DistinctOperator(keySelector, flushes)); }; } @@ -36,14 +35,14 @@ var DistinctSubscriber = (function (_super) { _this.keySelector = keySelector; _this.values = new Set(); if (flushes) { - _this.add(subscribeToResult_1.subscribeToResult(_this, flushes)); + _this.add(innerSubscribe_1.innerSubscribe(flushes, new innerSubscribe_1.SimpleInnerSubscriber(_this))); } return _this; } - DistinctSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) { + DistinctSubscriber.prototype.notifyNext = function () { this.values.clear(); }; - DistinctSubscriber.prototype.notifyError = function (error, innerSub) { + DistinctSubscriber.prototype.notifyError = function (error) { this._error(error); }; DistinctSubscriber.prototype._next = function (value) { @@ -74,6 +73,6 @@ var DistinctSubscriber = (function (_super) { } }; return DistinctSubscriber; -}(OuterSubscriber_1.OuterSubscriber)); +}(innerSubscribe_1.SimpleOuterSubscriber)); exports.DistinctSubscriber = DistinctSubscriber; //# sourceMappingURL=distinct.js.map \ No newline at end of file