WebsocketHandler

class base.NetworkHandler.WebsocketHandler(url: str, callbacks: Dict[str, Optional[Callable]], name: str)

Bases: object

WebsocketHandler, 用于处理最底层的websocket请求

初始化之后, 调用`start`启动另一个线程开始监听端口.

通常使用 send, send_later_if 两个方法发送数据.

Parameters

• url – 请求地址

• callbacks –

  一个dict, 包括:

  • on_send: function(cls, msg: str)

  • on_open: function(cls)

  • on_close: function(cls)

  • on_error: function(cls, error)

  • on_message: function(cls, msg: str)

  几个callback, 每个callback的值是None或一个function. 发生相应事件时调用相应callback. function的第一个参数是cls, 即是一个websocket.WebsocketApp类.

• name – 线程名

Methods Summary

join()	使用线程阻塞避免主程序提前结束.
send(msg)
send_later_if(msg, delay, condition)	在经过 delay (ms)后若 condition() 为 True 则发送 msg
start()

Methods Documentation

join()

使用线程阻塞避免主程序提前结束.

send(msg: Any)

send_later_if(msg: Any, delay: int, condition: Callable)

在经过 delay (ms)后若 condition() 为 True 则发送 msg

start()