fix bug of closing the same channel multiple times

This commit is contained in:
LouZhengwei 2016-11-24 23:41:48 +08:00 committed by GitHub
parent 124fb610dc
commit 9fe0b88f92

View File

@ -108,7 +108,6 @@ func (c *EndpointsConfig) Channel(source string) chan EndpointsUpdate {
for update := range endpointsCh { for update := range endpointsCh {
ch <- update ch <- update
} }
close(ch)
}() }()
return endpointsCh return endpointsCh
} }
@ -217,7 +216,6 @@ func (c *ServiceConfig) Channel(source string) chan ServiceUpdate {
for update := range serviceCh { for update := range serviceCh {
ch <- update ch <- update
} }
close(ch)
}() }()
return serviceCh return serviceCh
} }