Fix send on closed channel bug
Signed-off-by: Chun Chen <chenchun.feed@gmail.com> Upstream-commit: a408790de8f317d79fb52acb3a5220846a0ffcba Component: engine
This commit is contained in:
@@ -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()
|
||||
|
||||
Reference in New Issue
Block a user