client_connection.py 文件源码

def send(self, body):
        if isinstance(body, str):
            body = body.encode()
        try:
            self.writer.write(body)
            self.writer.write(b'\n')
        except BrokenPipeError:
            raise ConnectionClosed()