summaryrefslogtreecommitdiff
path: root/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
diff options
context:
space:
mode:
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts')
-rw-r--r--tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts17
1 files changed, 0 insertions, 17 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
deleted file mode 100644
index b53c566a14..0000000000
--- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/subscribeToObservable.ts
+++ /dev/null
@@ -1,17 +0,0 @@
-import { Subscriber } from '../Subscriber';
-import { observable as Symbol_observable } from '../symbol/observable';
-
-/**
- * Subscribes to an object that implements Symbol.observable with the given
- * Subscriber.
- * @param obj An object that implements Symbol.observable
- */
-export const subscribeToObservable = <T>(obj: any) => (subscriber: Subscriber<T>) => {
- const obs = obj[Symbol_observable]();
- if (typeof obs.subscribe !== 'function') {
- // Should be caught by observable subscribe function error handling.
- throw new TypeError('Provided object does not correctly implement Symbol.observable');
- } else {
- return obs.subscribe(subscriber);
- }
-};