PATH:
usr
/
local
/
lib
/
node_modules
/
ghost-cli
/
node_modules
/
rxjs
/
src
/
internal
/
util
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); }
[-] subscribeToResult.ts
[edit]
[-] isInteropObservable.ts
[edit]
[-] isArrayLike.ts
[edit]
[-] EmptyError.ts
[edit]
[-] subscribeToPromise.ts
[edit]
[-] isScheduler.ts
[edit]
[-] root.ts
[edit]
[+]
..
[-] applyMixins.ts
[edit]
[-] isObservable.ts
[edit]
[-] tryCatch.ts
[edit]
[-] subscribeToIterable.ts
[edit]
[-] subscribeToArray.ts
[edit]
[-] isPromise.ts
[edit]
[-] pipe.ts
[edit]
[-] identity.ts
[edit]
[-] ArgumentOutOfRangeError.ts
[edit]
[-] ObjectUnsubscribedError.ts
[edit]
[-] isIterable.ts
[edit]
[-] UnsubscriptionError.ts
[edit]
[-] not.ts
[edit]
[-] isArray.ts
[edit]
[-] isObject.ts
[edit]
[-] isNumeric.ts
[edit]
[-] isFunction.ts
[edit]
[-] noop.ts
[edit]
[-] canReportError.ts
[edit]
[-] errorObject.ts
[edit]
[-] TimeoutError.ts
[edit]
[-] isDate.ts
[edit]
[-] subscribeToObservable.ts
[edit]
[-] subscribeTo.ts
[edit]
[-] hostReportError.ts
[edit]
[-] toSubscriber.ts
[edit]
[-] Immediate.ts
[edit]