diff --git a/pkg/proxy/config/config.go b/pkg/proxy/config/config.go index 9653a82ae69..792644bc4b0 100644 --- a/pkg/proxy/config/config.go +++ b/pkg/proxy/config/config.go @@ -262,7 +262,8 @@ func (s *serviceStore) MergedState() interface{} { // watchForUpdates invokes bcaster.Notify() with the latest version of an object // when changes occur. func watchForUpdates(bcaster *config.Broadcaster, accessor config.Accessor, updates <-chan struct{}) { - for range updates { + for true { + <-updates bcaster.Notify(accessor.MergedState()) } }