diff options
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.ts | 17 |
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); - } -}; |