add missing await
This commit is contained in:
parent
9c62c2725a
commit
781eed7184
1 changed files with 1 additions and 1 deletions
|
@ -162,7 +162,7 @@ class RemoteOriginWriteProtocol(asyncio.DatagramProtocol):
|
|||
# need to check block numbers
|
||||
|
||||
if len(datagram.payload) == self.block_size:
|
||||
self.file.write(datagram.payload)
|
||||
await self.file.write(datagram.payload)
|
||||
self.retransmit_task = asyncio.create_task(
|
||||
timed_caller(
|
||||
itertools.chain((0,), self.timeout),
|
||||
|
|
Loading…
Reference in a new issue