diff --git a/src/Subject.ts b/src/Subject.ts index d984b3680e..e3d54216ad 100644 --- a/src/Subject.ts +++ b/src/Subject.ts @@ -115,15 +115,24 @@ export class AnonymousSubject extends Subject { } next(value: T) { - this.destination.next(value); + const { destination } = this; + if (destination && destination.next) { + destination.next(value); + } } error(err: any) { - this.destination.error(err); + const { destination } = this; + if (destination && destination.error) { + this.destination.error(err); + } } complete() { - this.destination.complete(); + const { destination } = this; + if (destination && destination.complete) { + this.destination.complete(); + } } _subscribe(subscriber: Subscriber): Subscription {