libgv/channel: break correct loop on reconnect

pkg/libgv/channel.go

@@ -147,6 +147,7 @@ func (c *Client) RunRealtimeChannel(ctx context.Context) error {
 			c.dispatchEvent(ctx, &RealtimeConnected{})
 		}
 		reader := utf16chunk.NewReader(resp.Body)
+	ReadLoop:
 		for {
 			var chunk []byte
 			chunk, err = reader.ReadChunk()
@@ -182,14 +183,15 @@ func (c *Client) RunRealtimeChannel(ctx context.Context) error {
 						return fmt.Errorf("failed to parse entry #%d: %w", i+1, err)
 					}
 					if len(parsed.GetDataWrapper()) == 1 && parsed.GetDataWrapper()[0].GetAltData().GetReconnect() {
+						_ = resp.Body.Close()
 						log.Debug().Msg("Got event that probably means we need to reconnect")
 						gSessionID, channel, err = c.SubscribeRealtimeChannel(ctx)
 						if err != nil {
 							return fmt.Errorf("failed to re-subscribe after timeout: %w", err)
 						}
 						lastResubscribe = time.Now()
 						ackID = 0
-						break
+						break ReadLoop
 					}
 					ackID = parsed.ArrayID
 					c.dispatchEvent(ctx, &RealtimeEvent{WebChannelEvent: &parsed})