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_esm2015%2Finternal%2Foperators%2FcatchError.js;h=248c29a5776608ce128cd29b74bc69dcd1a54e86;hp=8c2a62f800412efd2c1e94629e7ca0b329301a2c;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/catchError.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/catchError.js index 8c2a62f8..248c29a5 100644 --- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/catchError.js +++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/catchError.js @@ -1,6 +1,4 @@ -import { OuterSubscriber } from '../OuterSubscriber'; -import { InnerSubscriber } from '../InnerSubscriber'; -import { subscribeToResult } from '../util/subscribeToResult'; +import { SimpleOuterSubscriber, SimpleInnerSubscriber, innerSubscribe } from '../innerSubscribe'; export function catchError(selector) { return function catchErrorOperatorFunction(source) { const operator = new CatchOperator(selector); @@ -16,7 +14,7 @@ class CatchOperator { return source.subscribe(new CatchSubscriber(subscriber, this.selector, this.caught)); } } -class CatchSubscriber extends OuterSubscriber { +class CatchSubscriber extends SimpleOuterSubscriber { constructor(destination, selector, caught) { super(destination); this.selector = selector; @@ -33,9 +31,9 @@ class CatchSubscriber extends OuterSubscriber { return; } this._unsubscribeAndRecycle(); - const innerSubscriber = new InnerSubscriber(this, undefined, undefined); + const innerSubscriber = new SimpleInnerSubscriber(this); this.add(innerSubscriber); - const innerSubscription = subscribeToResult(this, result, undefined, undefined, innerSubscriber); + const innerSubscription = innerSubscribe(result, innerSubscriber); if (innerSubscription !== innerSubscriber) { this.add(innerSubscription); }