connection.py 文件源码

def _read_single(self):
        """
        Reads a single event off the websocket.
        """
        try:
            raw_data = await self._socket.recv()
        except (asyncio.CancelledError, websockets.ConnectionClosed) as e:
            if self._recv_await is None:
                self._recv_await = asyncio.Future(loop=self._loop)
            self._recv_await.set_result(False)
            raise e

        return json.loads(self._decode(raw_data))