Skip to content

Commit

Permalink
fix(take): remove redundant stop() call
Browse files Browse the repository at this point in the history
It is not necessary to call stop() inside TakeOperator._n, because TakeOperator._c will call
Stream._x tear down method which will call stop() on the Producer, which in this case is
TakeOperator.
  • Loading branch information
staltz committed Jun 12, 2016
1 parent 451b713 commit 625fb3e
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion src/core.ts
Original file line number Diff line number Diff line change
Expand Up @@ -910,7 +910,6 @@ export class TakeOperator<T> implements Operator<T, T> {
} else {
u._n(t);
u._c();
this._stop();
}
}

Expand Down

0 comments on commit 625fb3e

Please sign in to comment.