refactor: remove subscribeWith

ReactiveX · Jun 9, 2020 · 4bd71f0 · 4bd71f0
1 parent a9eaae8
commit 4bd71f0
Show file tree

Hide file tree

Showing 4 changed files with 2 additions and 71 deletions.
diff --git a/spec/util/subscribeWith-spec.ts b/spec/util/subscribeWith-spec.ts
diff --git a/src/internal/operators/finalize.ts b/src/internal/operators/finalize.ts
@@ -2,7 +2,6 @@ import { Operator } from '../Operator';
 import { Subscriber } from '../Subscriber';
 import { Observable } from '../Observable';
 import { MonoTypeOperatorFunction, TeardownLogic } from '../types';
-import { subscribeWith } from '../util/subscribeWith';
 
 /**
  * Returns an Observable that mirrors the source Observable, but will call a specified function when
@@ -68,7 +67,7 @@ class FinallyOperator<T> implements Operator<T, T> {
   }
 
   call(subscriber: Subscriber<T>, source: any): TeardownLogic {
-    const subscription = subscribeWith(source, subscriber);
+    const subscription = source.subscribe(subscriber);
     subscription.add(this.callback);
     return subscription;
   }

diff --git a/src/internal/util/subscribeToObservable.ts b/src/internal/util/subscribeToObservable.ts
@@ -1,6 +1,5 @@
 import { Subscriber } from '../Subscriber';
 import { observable as Symbol_observable } from '../symbol/observable';
-import { subscribeWith } from './subscribeWith';
 
 /**
  * Subscribes to an object that implements Symbol.observable with the given
@@ -13,6 +12,6 @@ export const subscribeToObservable = <T>(obj: any) => (subscriber: Subscriber<T>
     // Should be caught by observable subscribe function error handling.
     throw new TypeError('Provided object does not correctly implement Symbol.observable');
   } else {
-    return subscribeWith(obs, subscriber);
+    return obs.subscribe(subscriber);
   }
 };
diff --git a/src/internal/util/subscribeWith.ts b/src/internal/util/subscribeWith.ts