code: func (c *wsClient) readPump() {
  	defer func() {
  		c.broker.unregister <- c
  		c.conn.Close()
  	}()
  
  	for {
  		_, _, err := c.conn.ReadMessage()
  		if err != nil {
  			if websocket.IsUnexpectedCloseError(err, websocket.CloseGoingAway) {
  				beeLogger.Log.Errorf("An error happened when reading from the Websocket client: %v", err)
  			}
  			break
  		}
  	}
  }
docs: // readPump pumps messages from the websocket connection to the broker.