fix(take): terminate stream emission when TakeOperator recursively call itself
fix(take): terminate stream emission when TakeOperator recursively call itself

#158

staltz/xstream,staltz/xstream,andersonleite/xstream,andersonleite/xstream,andersonleite/xstream,staltz/xstream,staltz/xstream