PATH:
usr
/
local
/
lib
/
node_modules
/
ghost-cli
/
node_modules
/
rxjs
/
src
/
internal
/
util
import { Subscriber } from '../Subscriber'; import { Subject } from '../Subject'; /** * Determines whether the ErrorObserver is closed or stopped or has a * destination that is closed or stopped - in which case errors will * need to be reported via a different mechanism. * @param observer the observer */ export function canReportError(observer: Subscriber<any> | Subject<any>): boolean { while (observer) { const { closed, destination, isStopped } = observer as any; if (closed || isStopped) { return false; } else if (destination && destination instanceof Subscriber) { observer = destination; } else { observer = null; } } return true; }
[-] 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]