fix memory leak

desperatee · Nov 11, 2024 · 871cb21 · 871cb21
1 parent 8d11b72
commit 871cb21
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/rpc/ws/client.go b/rpc/ws/client.go
@@ -324,6 +324,7 @@ func (c *Client) subscribe(
 	c.conn.SetWriteDeadline(time.Now().Add(writeWait))
 	err = c.conn.WriteMessage(websocket.TextMessage, data)
 	if err != nil {
+		delete(c.subscriptionByRequestID, req.ID)
 		return nil, fmt.Errorf("unable to write request: %w", err)
 	}