fix(TakeOperator): terminate stream emission when TakeOperator recurs…

…ively call itself staltz#158
midnight-wonderer · Dec 16, 2016 · 3f30476 · 3f30476
1 parent f4dcbbe
commit 3f30476
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/core.ts b/src/core.ts
@@ -1177,9 +1177,10 @@ export class TakeOperator<T> implements Operator<T, T> {
   _n(t: T) {
     const u = this.out;
     if (u === NO) return;
-    if (this.taken++ < this.max - 1) {
+    const taken = ++this.taken;
+    if (taken < this.max) {
       u._n(t);
-    } else {
+    } else if (taken == this.max) {
       u._n(t);
       u._c();
     }