test(store/watch): add test case for slow event consumers
fix(store/watch): fix the slow consumer bug
Merge pull request #573 from cenkalti/stream-bug

Store: Fix slow consumer bug