异步服务器不刷新传输缓冲区

Question

我正在使用 asyncio.Protocol 类运行 asyncio TCP 服务器。当我在 data_received() 函数中使用数据变量时，我得到了所有通过套接字发送的数据。有没有办法在每次读取缓冲区时刷新缓冲区？这是我的代码：

def data_received(self, data):
    data = str(data)
    print("Received Data: ", data)

我可以在文档中找到的唯一刷新函数仅适用于我未使用的 StreamWriter 类。

Answer 1

在 Python 3 中，您可以使用 print 的 flush 关键字参数：

def data_received(self, data):
    data = str(data)
    print("Received Data: ", data, flush=True)

强制刷新流。请参阅documentation。