ws

package

v0.1.0 Latest Latest Go to latest Published: Apr 9, 2024 License: GPL-3.0 Imports: 6 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

func GetCtx(label string) *WSCtx

func NewWSCtx(conn *websocket.Conn) *WSCtx

func (ws *WSCtx) Read(p []byte) (n int, err error)

Read implements io.ReadWriter. only support BinaryMessage

func (ws *WSCtx) Receive(f func(messageType int, p []byte))

Receive This method will clog up

func (ws *WSCtx) Send(o any)

Send Use the default serialize send

func (ws *WSCtx) SetSerialize(serialize def.Serialize)

func (ws *WSCtx) SetWsLabel(label string) *WSCtx

func (ws *WSCtx) Write(p []byte) (n int, err error)

Write implements io.ReadWriter. only support BinaryMessage

func (ws *WSCtx) WriteJSON(o any)