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

2026-08-18 03:46:45 +00:00 · 2015-09-30 11:55:55 +00:00
parent 68e3bdac44
commit af4a35c67d
1 changed files with 1 additions and 0 deletions
@@ -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)