From a1f7509648368042e41401bc67b9556e2641952c Mon Sep 17 00:00:00 2001 From: Stephen J Day Date: Thu, 27 Jul 2017 14:22:11 -0700 Subject: [PATCH] events: close channel explicitly Signed-off-by: Stephen J Day --- events/exchange.go | 1 + 1 file changed, 1 insertion(+) diff --git a/events/exchange.go b/events/exchange.go index e78e5c204..5b8891ae4 100644 --- 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: