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%2FtakeUntil.js;h=38399f3e117f771de83de832b23f5564125fd65c;hp=72ea18e5837de2180946a4333be1731fce59e490;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/takeUntil.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/takeUntil.js index 72ea18e5..38399f3e 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/takeUntil.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm5/internal/operators/takeUntil.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 { innerSubscribe, SimpleInnerSubscriber, SimpleOuterSubscriber } from '../innerSubscribe'; export function takeUntil(notifier) { return function (source) { return source.lift(new TakeUntilOperator(notifier)); }; } @@ -11,7 +10,7 @@ var TakeUntilOperator = /*@__PURE__*/ (function () { } TakeUntilOperator.prototype.call = function (subscriber, source) { var takeUntilSubscriber = new TakeUntilSubscriber(subscriber); - var notifierSubscription = subscribeToResult(takeUntilSubscriber, this.notifier); + var notifierSubscription = innerSubscribe(this.notifier, new SimpleInnerSubscriber(takeUntilSubscriber)); if (notifierSubscription && !takeUntilSubscriber.seenValue) { takeUntilSubscriber.add(notifierSubscription); return source.subscribe(takeUntilSubscriber); @@ -27,12 +26,12 @@ var TakeUntilSubscriber = /*@__PURE__*/ (function (_super) { _this.seenValue = false; return _this; } - TakeUntilSubscriber.prototype.notifyNext = function (outerValue, innerValue, outerIndex, innerIndex, innerSub) { + TakeUntilSubscriber.prototype.notifyNext = function () { this.seenValue = true; this.complete(); }; TakeUntilSubscriber.prototype.notifyComplete = function () { }; return TakeUntilSubscriber; -}(OuterSubscriber)); +}(SimpleOuterSubscriber)); //# sourceMappingURL=takeUntil.js.map