Merge pull request #13906 from chenchun/closed_chan

Fix send on closed channel bug
2015-06-12 09:37:53 -04:00 · 2015-06-12 09:37:53 -04:00 · c98eafe564
commit c98eafe564
parent e70d680d72 a408790de8
1 changed files with 1 additions and 0 deletions
--- a/pkg/pubsub/publisher.go
+++ b/pkg/pubsub/publisher.go
@ -68,6 +68,7 @@ func (p *Publisher) Publish(v interface{}) {
 func (p *Publisher) Close() {
 	p.m.Lock()
 	for sub := range p.subscribers {
+		delete(p.subscribers, sub)
 		close(sub)
 	}
 	p.m.Unlock()