feat(stream watchers) fix locking issue
Merge pull request #18 from cenkalti/li

feat(stream watchers) fix locking issue