From af4a35c67daa2d551b7c9ae3b112936c1f3486f6 Mon Sep 17 00:00:00 2001 From: Tom Wilkie Date: Wed, 30 Sep 2015 11:53:02 +0000 Subject: [PATCH] Don't leak goroutines in multi publisher; fixes #531 --- xfer/multi_publisher.go | 1 + 1 file changed, 1 insertion(+) diff --git a/xfer/multi_publisher.go b/xfer/multi_publisher.go index 532525600..899551861 100644 --- a/xfer/multi_publisher.go +++ b/xfer/multi_publisher.go @@ -123,6 +123,7 @@ func (p *MultiPublisher) Stop() { func (p *MultiPublisher) appendFilter(list []tuple, f func(tuple) bool) []tuple { for _, t := range p.list { if !f(t) { + t.publisher.Stop() continue } list = append(list, t)