| 11 | type WebsocketConnSet map[*websocket.Conn]struct{} |
| 12 | |
| 13 | type WSConn struct { |
| 14 | sync.Mutex |
| 15 | conn *websocket.Conn |
| 16 | writeChan chan []byte |
| 17 | maxMsgLen uint32 |
| 18 | closeFlag bool |
| 19 | } |
| 20 | |
| 21 | func newWSConn(conn *websocket.Conn, pendingWriteNum int, maxMsgLen uint32) *WSConn { |
| 22 | wsConn := new(WSConn) |
nothing calls this directly
no outgoing calls
no test coverage detected