websocket

type Factory func() (*recws.RecConn, error)

type Option interface {
	Apply(*recws.RecConn)
}

type OptionFunc func(*recws.RecConn)

type Pool interface {
	Get() (*PoolConn, error)
	Close()
	Len() int
}

type PoolConn struct {
	Conn *recws.RecConn
	// contains filtered or unexported fields
}

type WsConn interface {
	Dial(urlStr string, reqHeader http.Header)
	IsConnected() bool
	Close()
	WriteMessage(messageType int, data []byte) error
	ReadMessage() (messageType int, message []byte, err error)
	WriteJSON(v interface{}) error
	ReadJSON(v interface{}) error
	MarkUnusable()
	CloseAndReconnect()
}