You should have a local ```n``` here which can be decremented by each subscriber independently. The current version shares the ```n``` for all subscribers, which is a very common bug.