alemi/aiocraft
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity

finish processing packets upon disconnect

Browse source
This commit is contained in:
əlemi 2021-11-22 15:25:41 +01:00
parent ce22e26458
commit 72b4a5a43b
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
aiocraft/dispatcher.py
View file

@ -71,7 +71,7 @@ class Dispatcher:
return self._outgoing.qsize() return self._outgoing.qsize()
async def packets(self, timeout=1) -> AsyncIterator[Packet]: async def packets(self, timeout=1) -> AsyncIterator[Packet]:
while self.connected: while self.connected or self._incoming.qsize(): # Finish processing packets on disconnect
try: # TODO replace this timed busy-wait with an event which resolves upon disconnection, and await both try: # TODO replace this timed busy-wait with an event which resolves upon disconnection, and await both
packet = await asyncio.wait_for(self._incoming.get(), timeout=timeout) packet = await asyncio.wait_for(self._incoming.get(), timeout=timeout)
try: try: