ws

Documentation

Index

• type WSCtx
  • func GetCtx(label string) *WSCtx
  • func NewWSCtx(conn *websocket.Conn) *WSCtx
  • func (ws *WSCtx) Read(p []byte) (n int, err error)
  • func (ws *WSCtx) Receive(f func(messageType int, p []byte))
  • func (ws *WSCtx) Send(o any)
  • func (ws *WSCtx) SetSerialize(serialize def.Serialize)
  • func (ws *WSCtx) SetWsLabel(label string) *WSCtx
  • func (ws *WSCtx) Write(p []byte) (n int, err error)
  • func (ws *WSCtx) WriteJSON(o any)

Types

type WSCtx

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

func GetCtx

func GetCtx(label string) *WSCtx

func NewWSCtx

func NewWSCtx(conn *websocket.Conn) *WSCtx

func (*WSCtx) Read

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

Read implements io.ReadWriter. only support BinaryMessage

func (*WSCtx) Receive

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

Receive This method will clog up

func (*WSCtx) Send

func (ws *WSCtx) Send(o any)

Send Use the default serialize send

func (*WSCtx) SetSerialize

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

func (*WSCtx) SetWsLabel

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

func (*WSCtx) Write

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

Write implements io.ReadWriter. only support BinaryMessage

func (*WSCtx) WriteJSON

func (ws *WSCtx) WriteJSON(o any)