impl

type Connection ¶

type Connection struct {
	// contains filtered or unexported fields
}

SendMessage 将消息投递到out channel ReadMessage 从 in channel 读取消息 起两个协程

读协程，循环读取websocket，将消息投递到in channel
写协程，循环读取 out channel，将消息写回 websocket

func InitConnection(wsConn *websocket.Conn) (conn *Connection, err error)

func (conn *Connection) Close()

func (conn *Connection) ReadMessage() (data []byte, err error)

func (conn *Connection) WriteMessage(data []byte) (err error)