Close watch channel on exit

2025-09-01 15:37:31 +00:00 · 2020-09-25 18:03:59 -07:00
parent 09d79b238b
commit 4e31a4b24b
1 changed files with 1 additions and 0 deletions
--- a/pkg/summarycache/summarycache.go
+++ b/pkg/summarycache/summarycache.go
@@ -81,6 +81,7 @@ func (s *SummaryCache) OnInboundRelationshipChange(ctx context.Context, schema *
 		<-ctx.Done()
 		s.Lock()
 		defer s.Unlock()
+		close(cb)
 		delete(s.cbs, id)
 	}()