diff --git a/src/internal/util/canReportError.ts b/src/internal/util/canReportError.ts index f66012e70c..caa98f7ea6 100644 --- a/src/internal/util/canReportError.ts +++ b/src/internal/util/canReportError.ts @@ -1,5 +1,5 @@ -import { isTrustedSubscriber } from '../Subscriber'; -import { ErrorObserver } from '../types'; +import { isTrustedSubscriber, Subscriber } from '../Subscriber'; +import { Subject } from '../Subject'; /** * Determines whether the ErrorObserver is closed or stopped or has a @@ -7,7 +7,7 @@ import { ErrorObserver } from '../types'; * need to be reported via a different mechanism. * @param observer the observer */ -export function canReportError(observer: ErrorObserver): boolean { +export function canReportError(observer: Subscriber | Subject): boolean { while (observer) { const { closed, destination, isStopped } = observer as any; if (closed || isStopped) {