diff --git a/consul.go b/consul.go index b4eae0c..9890533 100644 --- a/consul.go +++ b/consul.go @@ -247,9 +247,10 @@ func (w *consulWatcher) run() { delete(dstmp, sk) } } - - w.vchan <- dstmp - src = dst + if len(dstmp) > 0 { + w.vchan <- dstmp + src = dst + } } } }