diff --git a/store/watcher_hub.go b/store/watcher_hub.go index 36612199d..de9003575 100644 --- a/store/watcher_hub.go +++ b/store/watcher_hub.go @@ -47,7 +47,7 @@ func (wh *watcherHub) watch(key string, recursive, stream bool, index, storeInde } w := &watcher{ - eventChan: make(chan *Event, 1), // use a buffered channel + eventChan: make(chan *Event, 100), // use a buffered channel recursive: recursive, stream: stream, sinceIndex: index,