From 52d3c50217f9be91b726cc07764d20a3ea6bcf09 Mon Sep 17 00:00:00 2001
From: Chun Chen <chenchun.feed@gmail.com>
Date: Fri, 12 Jun 2015 15:42:34 +0800
Subject: [PATCH] Fix send on closed channel bug

Signed-off-by: Chun Chen <chenchun.feed@gmail.com>
Upstream-commit: a408790de8f317d79fb52acb3a5220846a0ffcba
Component: engine
---
 components/engine/pkg/pubsub/publisher.go | 1 +
 1 file changed, 1 insertion(+)

diff --git a/components/engine/pkg/pubsub/publisher.go b/components/engine/pkg/pubsub/publisher.go
index f017262ae3..534b74ad4d 100644
--- a/components/engine/pkg/pubsub/publisher.go
+++ b/components/engine/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()