The event channel for watches can drop events too easily in the case of streaming watches. This increases the buffer to a more useful level.
@@ -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,