Improve explanation comment as to why we're waiting ourselfs

This commit is contained in:
Matthias 2022-11-03 06:50:18 +01:00
parent b749f3edd6
commit ff619edebf
1 changed files with 3 additions and 2 deletions

View File

@ -76,8 +76,9 @@ class WebSocketChannel:
"""
# This block only runs if the queue is full, it will wait
# until self.drain_timeout for the relay to drain the outgoing
# queue
# until self.drain_timeout for the relay to drain the outgoing queue
# We can't use asyncio.wait_for here because the queue may have been created with a
# different eventloop
start = time.time()
while self.queue.full():
await asyncio.sleep(1)