oops was a loop
This commit is contained in:
parent
838982c261
commit
cde96c3cd5
1 changed files with 1 additions and 1 deletions
|
@ -273,7 +273,7 @@ class Dispatcher:
|
||||||
await self.disconnect(block=False)
|
await self.disconnect(block=False)
|
||||||
|
|
||||||
async def _up_worker(self, timeout=1):
|
async def _up_worker(self, timeout=1):
|
||||||
while True:
|
while self._dispatching:
|
||||||
try:
|
try:
|
||||||
packet : Packet = await asyncio.wait_for(self._outgoing.get(), timeout=timeout)
|
packet : Packet = await asyncio.wait_for(self._outgoing.get(), timeout=timeout)
|
||||||
except asyncio.TimeoutError:
|
except asyncio.TimeoutError:
|
||||||
|
|
Loading…
Reference in a new issue