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%2FtimeoutWith.js;h=e463f6613fad77e4564366523b0e553eca26ef40;hp=0526cc7114d870f9d5008f13232ff7348e37e093;hb=4d07c77cf4d78cab8639e13ddc3c22495e585b0b;hpb=b3950616b54221c40a7dab9099bda675007e5b6e

diff --git a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/timeoutWith.js b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/timeoutWith.js
index 0526cc71..e463f661 100644
--- a/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/timeoutWith.js
+++ b/.config/coc/extensions/node_modules/coc-prettier/node_modules/rxjs/_esm2015/internal/operators/timeoutWith.js
@@ -1,7 +1,6 @@
 import { async } from '../scheduler/async';
 import { isDate } from '../util/isDate';
-import { OuterSubscriber } from '../OuterSubscriber';
-import { subscribeToResult } from '../util/subscribeToResult';
+import { SimpleOuterSubscriber, innerSubscribe, SimpleInnerSubscriber } from '../innerSubscribe';
 export function timeoutWith(due, withObservable, scheduler = async) {
     return (source) => {
         let absoluteTimeout = isDate(due);
@@ -20,20 +19,19 @@ class TimeoutWithOperator {
         return source.subscribe(new TimeoutWithSubscriber(subscriber, this.absoluteTimeout, this.waitFor, this.withObservable, this.scheduler));
     }
 }
-class TimeoutWithSubscriber extends OuterSubscriber {
+class TimeoutWithSubscriber extends SimpleOuterSubscriber {
     constructor(destination, absoluteTimeout, waitFor, withObservable, scheduler) {
         super(destination);
         this.absoluteTimeout = absoluteTimeout;
         this.waitFor = waitFor;
         this.withObservable = withObservable;
         this.scheduler = scheduler;
-        this.action = null;
         this.scheduleTimeout();
     }
     static dispatchTimeout(subscriber) {
         const { withObservable } = subscriber;
         subscriber._unsubscribeAndRecycle();
-        subscriber.add(subscribeToResult(subscriber, withObservable));
+        subscriber.add(innerSubscribe(withObservable, new SimpleInnerSubscriber(subscriber)));
     }
     scheduleTimeout() {
         const { action } = this;
@@ -51,7 +49,7 @@ class TimeoutWithSubscriber extends OuterSubscriber {
         super._next(value);
     }
     _unsubscribe() {
-        this.action = null;
+        this.action = undefined;
         this.scheduler = null;
         this.withObservable = null;
     }