(conn *websocket.Conn)
| 25 | ) |
| 26 | |
| 27 | func NewWsConnection(conn *websocket.Conn) *WsConnection { |
| 28 | ws := &WsConnection{} |
| 29 | ws.ws = conn |
| 30 | ws.readChan = make(chan []byte, 10) |
| 31 | ws.writeChan = make(chan []byte, 10) |
| 32 | ws.closeChan = make(chan bool) |
| 33 | ws.isOpen = true |
| 34 | ws.connId = uuid.NewV5(uuid.NewV4(), "ws").String() |
| 35 | go ws.read() |
| 36 | go ws.send() |
| 37 | return ws |
| 38 | } |
| 39 | func (w *WsConnection) SetIp(ip string) { |
| 40 | w.clientIp = ip |
| 41 | } |