code: func handleWsRequest(broker *wsBroker, w http.ResponseWriter, r *http.Request) {
  	conn, err := upgrader.Upgrade(w, r, nil)
  	if err != nil {
  		beeLogger.Log.Errorf("error while upgrading server connection: %v", err)
  		return
  	}
  
  	client := &wsClient{
  		broker: broker,
  		conn:   conn,
  		send:   make(chan []byte, 256),
  	}
  	client.broker.register <- client
  
  	go client.writePump()
  	client.readPump()
  }
docs: // handleWsRequest handles websocket requests from the peer.