Don't leak goroutines in multi publisher; fixes #531

weaveworks · Sep 30, 2015 · af4a35c · af4a35c
1 parent 68e3bda
commit af4a35c
Showing 1 changed file with 1 addition and 0 deletions.
diff --git 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)