connection.py 文件源码

def _read(self):
        """
        Endless read loop that runs until the socket is closed.
        """
        while True:
            try:
                data = await self._read_single()
            except (asyncio.CancelledError, websockets.ConnectionClosed):
                break  # will already be handled
            except Exception as e:
                logger.error("error in interactive read loop", extra=e)
                break

            if isinstance(data, list):
                for item in data:
                    self._handle_recv(item)
            else:
                self._handle_recv(data)