Преглед изворни кода

Fix send on closed channel bug

Signed-off-by: Chun Chen <chenchun.feed@gmail.com>
Chun Chen пре 10 година
родитељ
комит
a408790de8
1 измењених фајлова са 1 додато и 0 уклоњено
  1. 1 0
      pkg/pubsub/publisher.go

+ 1 - 0
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()