fix: update based on feedback

Bisonai · Aug 27, 2024 · f10563a · f10563a
1 parent d90c3b5
commit f10563a
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/node/pkg/chain/websocketchainreader/websocketreader.go b/node/pkg/chain/websocketchainreader/websocketreader.go
@@ -116,6 +116,7 @@ func (c *ChainReader) handleSubscription(ctx context.Context, config *SubscribeC
 		}
 
 		headerSubChan := make(chan *types.Header, 1)
+		defer close(headerSubChan)
 		// Subscribe to new head just to keep connection alive (ignoring the results)
 		subNewHead, err := c.client(config.ChainType).SubscribeNewHead(ctx, headerSubChan)
 		if err != nil {