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

ops this queue cannot be cleared

Browse source
This commit is contained in:
əlemi 2021-11-27 21:08:41 +01:00
parent a4dd9c5672
commit 5705cb4231
1 changed files with 0 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

1
aiocraft/dispatcher.py
View file

@ -133,7 +133,6 @@ class Dispatcher:
async def disconnect(self, block:bool=True): async def disconnect(self, block:bool=True):
self._dispatching = False self._dispatching = False
self._outgoing.clear()
if block and self._writer and self._reader: if block and self._writer and self._reader:
await asyncio.gather(self._writer, self._reader) await asyncio.gather(self._writer, self._reader)
self._logger.debug("Net workers stopped") self._logger.debug("Net workers stopped")