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%2Fsrc%2Finternal%2Foperators%2Fexhaust.ts;h=54c5002a307d6591c448cdd7e40ddde20949d915;hp=ad14b760d65c604286dd6e52808026053b1fdaca;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
index ad14b760..54c5002a 100644
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/src/internal/operators/exhaust.ts
@@ -1,10 +1,8 @@
 import { Operator } from '../Operator';
 import { Observable } from '../Observable';
 import { Subscriber } from '../Subscriber';
-import { Subscription } from '../Subscription';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
 import { ObservableInput, OperatorFunction, TeardownLogic } from '../types';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 
 export function exhaust<T>(): OperatorFunction<ObservableInput<T>, T>;
 export function exhaust<R>(): OperatorFunction<any, R>;
@@ -68,7 +66,7 @@ class SwitchFirstOperator<T> implements Operator<T, T> {
  * @ignore
  * @extends {Ignored}
  */
-class SwitchFirstSubscriber<T> extends OuterSubscriber<T, T> {
+class SwitchFirstSubscriber<T> extends SimpleOuterSubscriber<T, T> {
   private hasCompleted: boolean = false;
   private hasSubscription: boolean = false;
 
@@ -79,22 +77,21 @@ class SwitchFirstSubscriber<T> extends OuterSubscriber<T, T> {
   protected _next(value: T): void {
     if (!this.hasSubscription) {
       this.hasSubscription = true;
-      this.add(subscribeToResult(this, value));
+      this.add(innerSubscribe(value, new SimpleInnerSubscriber(this)));
     }
   }
 
   protected _complete(): void {
     this.hasCompleted = true;
     if (!this.hasSubscription) {
-      this.destination.complete();
+      this.destination.complete!();
     }
   }
 
-  notifyComplete(innerSub: Subscription): void {
-    this.remove(innerSub);
+  notifyComplete(): void {
     this.hasSubscription = false;
     if (this.hasCompleted) {
-      this.destination.complete();
+      this.destination.complete!();
     }
   }
 }