close the info buffer channel on shutdown

signalfx · Nov 24, 2023 · 0ed7e0e · 0ed7e0e
1 parent 82902f8
commit 0ed7e0e
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/signalflow/computation.go b/signalflow/computation.go
@@ -338,6 +338,7 @@ func (c *Computation) StopWithReason(ctx context.Context, reason string) error {
 func (c *Computation) shutdown() {
 	close(c.dataChBuffer)
 	close(c.expirationChBuffer)
+	close(c.infoChBuffer)
 }
 
 var ErrMetadataTimeout = errors.New("metadata value did not come in time")