fix: fixing deadlock caused by read mutex

v1/client/client.go

@@ -253,32 +253,30 @@ func (wsClient *SafeWebsocketClient) startReceiveHandler(ctx context.Context) {
 			log.Println("receive handler stopped")
 			return
 		default:
-			if err := wsClient.mu.ReadHandler(func() error {
 			conn := wsClient.conn
 
 			if conn == nil {
 				wsClient.triggerReconnect()
-					return fmt.Errorf("connection closed")
+				return
+				// return fmt.Errorf("connection closed")
 			}
 			_, message, err := conn.ReadMessage()
 			if err != nil {
 				wsClient.triggerReconnect()
-					return fmt.Errorf("failed to read message: %v", err)
+				// return fmt.Errorf("failed to read message: %v", err)
+				return
 			}
 			select {
 			case wsClient.dataChannel <- message:
 			case <-ctx.Done():
 				log.Println("Reconnect handler stopped")
-					return nil
+				return
 			default:
 				log.Println("Data channel full, dropping message")
 			}
-				return nil
-			}); err != nil {
 			return
 		}
 	}
-	}
 }
 
 func (wsClient *SafeWebsocketClient) triggerReconnect() {