diff options
Diffstat (limited to 'tools/node_modules/eslint/node_modules/rxjs/src/internal/util/toSubscriber.ts')
-rw-r--r-- | tools/node_modules/eslint/node_modules/rxjs/src/internal/util/toSubscriber.ts | 26 |
1 files changed, 0 insertions, 26 deletions
diff --git a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/toSubscriber.ts b/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/toSubscriber.ts deleted file mode 100644 index e03d1400ae..0000000000 --- a/tools/node_modules/eslint/node_modules/rxjs/src/internal/util/toSubscriber.ts +++ /dev/null @@ -1,26 +0,0 @@ -import { Subscriber } from '../Subscriber'; -import { rxSubscriber as rxSubscriberSymbol } from '../symbol/rxSubscriber'; -import { empty as emptyObserver } from '../Observer'; -import { PartialObserver } from '../types'; - -export function toSubscriber<T>( - nextOrObserver?: PartialObserver<T> | ((value: T) => void), - error?: (error: any) => void, - complete?: () => void): Subscriber<T> { - - if (nextOrObserver) { - if (nextOrObserver instanceof Subscriber) { - return (<Subscriber<T>> nextOrObserver); - } - - if (nextOrObserver[rxSubscriberSymbol]) { - return nextOrObserver[rxSubscriberSymbol](); - } - } - - if (!nextOrObserver && !error && !complete) { - return new Subscriber(emptyObserver); - } - - return new Subscriber(nextOrObserver, error, complete); -} |