backend.py 文件源码

def __init__(self, url, watchdog=None, loop=None):
        self._resp_queue = asyncio.Queue(loop=loop)
        self.loop = loop
        assert url.startswith('ws://') or url.startswith('wss://')
        self.url = url
        self._websocket = None
        self._ws_recv_handler_task = None
        self._watchdog_task = None
        self.watchdog_time = watchdog
        self._signal_ns = blinker.Namespace()