diff --git a/store/watcher.go b/store/watcher.go index faa0cffed..6bc353f58 100644 --- a/store/watcher.go +++ b/store/watcher.go @@ -124,10 +124,10 @@ func (w *WatcherHub) notify(resp Response) error { // stopWatchers stops all the watchers // This function is used when the etcd recovery from a snapshot at runtime func (w *WatcherHub) stopWatchers() { - for _, subWatchers := range w.watchers{ - for _, watcher := range subWatchers{ + for _, subWatchers := range w.watchers { + for _, watcher := range subWatchers { watcher.C <- nil } } w.watchers = nil -} \ No newline at end of file +}