Merge pull request #1254 from stevvooe/close-channel

events: close channel explicitly
2017-07-27 15:59:50 -07:00 · 2017-07-27 15:59:50 -07:00 · 4e299a9a20
commit 4e299a9a20
parent 1679727648 a1f7509648
1 changed files with 1 additions and 0 deletions
--- a/events/exchange.go
+++ b/events/exchange.go
@ -98,6 +98,7 @@ func (e *Exchange) Subscribe(ctx context.Context, filters ...filters.Filter) (ch
 		defer close(errq)
 		defer e.broadcaster.Remove(queue)
 		defer queue.Close()
+		defer channel.Close()

 		var err error
 	loop: