fix(take): complete on limit reached

ReactiveX · Aug 27, 2015 · 801a711 · 801a711
1 parent 9f8347f
commit 801a711
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/operators/take.ts b/src/operators/take.ts
@@ -30,10 +30,12 @@ export class TakeSubscriber<T> extends Subscriber<T> {
   }
 
   _next(x) {
-    if (++this.count <= this.total) {
+    const total = this.total;
+    if (++this.count <= total) {
       this.destination.next(x);
-    } else {
-      this.destination.complete();
+      if (this.count === total) {
+        this.destination.complete();
+      }
     }
   }
 }