Method Read

agent/utils/websocket/client.go:26–38

()

}

func (c *Client) Read() {
	defer func() {
		c.closed.Store(true)
		close(c.Msg)
	}()
	for {
		_, message, err := c.Socket.ReadMessage()
		if err != nil {
			return
		}
		ProcessData(c, message)
	}
}

func (c *Client) Write() {
	defer c.Socket.Close()