wsclient

Aug 12, 2021

Changes in this version

+ const HeaderSize

+ const ProtectLongPacketSize

+ const TimeOut

+ type WebSocket struct

+ func NewWebSocket(url string, client *WsClient) (*WebSocket, error)

+ func (this *WebSocket) Close() *promise.Promise

+ func (this *WebSocket) ServeIO()

+ type WsClient struct

+ Closing bool

+ Opening bool

+ func NewWsClient() *WsClient

+ func (this *WsClient) AsyncCall(transId uint32, req interface{}) (interface{}, error)

+ func (this *WsClient) Call(transId uint32, req interface{}) (interface{}, error)

+ func (this *WsClient) ClearContext()

+ func (this *WsClient) Close() *promise.Promise

+ func (this *WsClient) Connect(addr string) *promise.Promise

+ func (this *WsClient) Connected() bool

+ func (this *WsClient) Disconnect(force bool) *promise.Promise

+ func (this *WsClient) HookRecv(data []byte) (interface{}, error)

+ func (this *WsClient) Off(cmdId uint16, listener events.Listener)

+ func (this *WsClient) OnClose(conn *websocket.Conn)

+ func (this *WsClient) OnMessage(cmdId protocol.BINARY_TAG, listeners ...events.Listener)

+ func (this *WsClient) OnOpen(conn *websocket.Conn)

+ func (this *WsClient) OnRecv(connect lokas.IConn, data []byte)

+ func (this *WsClient) OnRecvCmd(cmdId protocol.BINARY_TAG, time time.Duration) *promise.Promise

+ func (this *WsClient) OnRecvData(data []byte)

+ func (this *WsClient) OnRecvMessage(cmdId protocol.BINARY_TAG, transId uint32, msg interface{})

+ func (this *WsClient) Open() *promise.Promise

+ func (this *WsClient) Request(req interface{}) *promise.Promise

+ func (this *WsClient) Run()

+ func (this *WsClient) SendMessage(transId uint32, msg interface{})