diff --git a/src/operator/catch.ts b/src/operator/catch.ts index 44cbe71ee7..450d40b0da 100644 --- a/src/operator/catch.ts +++ b/src/operator/catch.ts @@ -39,6 +39,7 @@ class CatchSubscriber extends Subscriber { private caught: Observable) { super(null); this.lastSubscription = this; + this.destination.add(this); } _next(value: T) {