not necessary to hold the packet queue when upgrading

miguelgrinberg · Mar 16, 2019 · 330c6b9 · 330c6b9
1 parent 138fb60
commit 330c6b9
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/engineio/asyncio_socket.py b/engineio/asyncio_socket.py
@@ -132,7 +132,6 @@ async def _websocket_handler(self, ws):
         if self.connected:
             # the socket was already connected, so this is an upgrade
             self.upgrading = True  # hold packet sends during the upgrade
-            await self.queue.join()  # flush the queue first
 
             try:
                 pkt = await ws.wait()

diff --git a/engineio/socket.py b/engineio/socket.py
@@ -155,7 +155,6 @@ def _websocket_handler(self, ws):
         if self.connected:
             # the socket was already connected, so this is an upgrade
             self.upgrading = True  # hold packet sends during the upgrade
-            self.queue.join()  # flush the queue first
 
             pkt = ws.wait()
             decoded_pkt = packet.Packet(encoded_packet=pkt)