fix(groupBy): Fix groupBy to dispose of outer subscription.

ReactiveX · Dec 19, 2016 · 04b7757 · 04b7757
1 parent dc06e01
commit 04b7757
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/operator/groupBy.ts b/src/operator/groupBy.ts
@@ -163,7 +163,7 @@ class GroupBySubscriber<T, K, R> extends Subscriber<T> implements RefCountSubscr
  }
 
  unsubscribe() {
- if (!this.closed && !this.attemptedToUnsubscribe) {
+ if (!this.closed) {
  this.attemptedToUnsubscribe = true;
  if (this.count === 0) {
  super.unsubscribe();