socket.py 文件源码

def _read(self, count, blocking=True):
        try:
            if blocking:
                data = self.sock.recv(count)
            else:
                data = self.sock.recv(count, socket.MSG_DONTWAIT)
        except BlockingIOError:
            return None

        if len(data) == 0:
            raise SocketConnError("Connection probably closed")
        return data