Fixed poll() method to always empty the queue

Fixes miguelgrinberg/Flask-SocketIO#589
miguelgrinberg · Nov 20, 2017 · e8e665b · e8e665b
1 parent 212bede
commit e8e665b
Showing 1 changed file with 6 additions and 5 deletions.
diff --git a/engineio/socket.py b/engineio/socket.py
@@ -33,11 +33,12 @@ def poll(self):
             raise exceptions.QueueEmpty()
         if packets == [None]:
             return []
-        try:
-            packets.append(self.queue.get(block=False))
-            self.queue.task_done()
-        except self.server._async['queue'].Empty:
-            pass
+        while True:
+            try:
+                packets.append(self.queue.get(block=False))
+                self.queue.task_done()
+            except self.server._async['queue'].Empty:
+                break
         return packets
 
     def receive(self, pkt):