diff --git a/src/operator/bufferToggle.ts b/src/operator/bufferToggle.ts index 739c448937..dfa6111bfc 100644 --- a/src/operator/bufferToggle.ts +++ b/src/operator/bufferToggle.ts @@ -92,7 +92,8 @@ class BufferToggleSubscriber extends Subscriber { contexts.push(context); const subscriber = new BufferToggleClosingsSubscriber(this, context); const subscription = closingNotifier._subscribe(subscriber); - this.add(context.subscription.add(subscription)); + context.subscription.add(subscription); + this.add(subscription); } }