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%2F_esm5%2Finternal%2Foperators%2Fdistinct.js;h=4119529b47d5056b98c7f7ee93e6797d4888db4a;hp=482c9051fa7892006e69c506a7971b61e5187024;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/distinct.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/distinct.js index 482c9051..4119529b 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/distinct.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/distinct.js @@ -1,7 +1,6 @@ -/** PURE_IMPORTS_START tslib,_OuterSubscriber,_util_subscribeToResult PURE_IMPORTS_END */ +/** PURE_IMPORTS_START tslib,_innerSubscribe PURE_IMPORTS_END */ import * as tslib_1 from "tslib"; -import { OuterSubscriber } from '../OuterSubscriber'; -import { subscribeToResult } from '../util/subscribeToResult'; +import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe'; export function distinct(keySelector, flushes) { return function (source) { return source.lift(new DistinctOperator(keySelector, flushes)); }; } @@ -22,14 +21,14 @@ var DistinctSubscriber = /*@__PURE__*/ (function (_super) { _this.keySelector = keySelector; _this.values = new Set(); if (flushes) { - _this.add(subscribeToResult(_this, flushes)); + _this.add(innerSubscribe(flushes, new 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) { @@ -60,6 +59,6 @@ var DistinctSubscriber = /*@__PURE__*/ (function (_super) { } }; return DistinctSubscriber; -}(OuterSubscriber)); +}(SimpleOuterSubscriber)); export { DistinctSubscriber }; //# sourceMappingURL=distinct.js.map