Drain buffer after read

2019-01-01 21:30:55 +00:00 · 2019-01-01 21:30:55 +00:00 · d9a353e505
parent b7e7e868c9
commit d9a353e505
1 changed files with 1 additions and 0 deletions
--- a/tcp_nat_proxy.py
+++ b/tcp_nat_proxy.py
@ -26,6 +26,7 @@ async def pipe(reader, writer):
    try:
        while not reader.at_eof():
            writer.write(await reader.read(BUFFER_SIZE))
+            await writer.drain()
    finally:
        writer.close()