Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
fix(take): remove redundant stop() call
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