diff --git a/client.go b/client.go
index a45a0f9..3a72aad 100644
--- a/client.go
+++ b/client.go
@@ -248,6 +248,8 @@ func (c *Client) ReadPump() {
 		c.Close()
 	}()
 
+	go c.processMessages()
+
 	addr := c.RemoteAddr()
 	c.mu.Lock()
 	conn := c.conn
@@ -279,8 +281,6 @@ func (c *Client) ReadPump() {
 		return nil
 	})
 
-	go c.processMessages()
-
 	for {
 		conn.SetReadDeadline(time.Now().Add(pongWait)) // nolint
 		messageType, reader, err := conn.NextReader()