From 8597904bc26f5b89057dcf7533ed36cd9ed62097 Mon Sep 17 00:00:00 2001 From: Cenk Alti Date: Fri, 10 Jan 2014 16:04:23 +0200 Subject: [PATCH] feat(stream watchers) fix locking issue --- store/watcher_hub.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/store/watcher_hub.go b/store/watcher_hub.go index 3a62066e7..aeda171a9 100644 --- a/store/watcher_hub.go +++ b/store/watcher_hub.go @@ -87,16 +87,6 @@ func (wh *watcherHub) watch(key string, recursive, stream bool, index uint64) (* if l.Len() == 0 { delete(wh.watchers, key) } - - // consume all items in the channel - // unblock all the waiting go routines created by watchHub - for { - select { - case <-w.EventChan: - default: - break - } - } } atomic.AddInt64(&wh.count, 1)