Skip to content

Commit d9da01a

Browse files
authored
Wait for stream close before returning from callback.
1 parent b5e72fa commit d9da01a

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

python/s3daemon/s3daemon.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -73,6 +73,9 @@ async def handle_client(client, reader, writer):
7373
writer.write(b"Success")
7474
except Exception as e:
7575
writer.write(bytes(repr(e), "UTF-8"))
76+
await writer.drain()
77+
writer.close()
78+
await writer.wait_closed()
7679
log.info("%f %f sec", start, time.time() - start)
7780

7881

0 commit comments

Comments
 (0)