refactor(groupBy): clear groups via map.clear interface

closes #1257
ReactiveX · Feb 10, 2016 · ace3932 · ace3932
1 parent e3fbd05
commit ace3932
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/src/operator/groupBy.ts b/src/operator/groupBy.ts
@@ -132,8 +132,9 @@ class GroupBySubscriber<T, K, R> extends Subscriber<T> implements RefCountSubscr
     if (groups) {
       groups.forEach((group, key) => {
         group.error(err);
-        this.removeGroup(key);
       });
+
+      groups.clear();
     }
     this.destination.error(err);
   }
@@ -143,8 +144,9 @@ class GroupBySubscriber<T, K, R> extends Subscriber<T> implements RefCountSubscr
     if (groups) {
       groups.forEach((group, key) => {
         group.complete();
-        this.removeGroup(key);
       });
+
+      groups.clear();
     }
     this.destination.complete();
   }