fix: remove unnecessary threading

node/pkg/chain/websocketchainreader/websocketreader.go

@@ -115,26 +115,14 @@ func (c *ChainReader) handleSubscription(ctx context.Context, config *SubscribeC
 			Addresses: []common.Address{common.HexToAddress(config.Address)},
 		}
 
-		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)
+		subNewHead, err := c.client(config.ChainType).SubscribeNewHead(ctx, nil)
 		if err != nil {
 			log.Warn().Err(err).Msg("Failed to subscribe to new head")
 		} else {
 			defer subNewHead.Unsubscribe()
 		}
 
-		go func() {
-			for {
-				select {
-				case <-ctx.Done():
-					return
-				case <-headerSubChan:
-				}
-			}
-		}()
-
 		logs := make(chan types.Log)
 		sub, err := c.client(config.ChainType).SubscribeFilterLogs(ctx, query, logs)
 		if err != nil {