diff --git a/src/p4p/client/asyncio.py b/src/p4p/client/asyncio.py
index 74aeb2ed..5089401d 100644
--- a/src/p4p/client/asyncio.py
+++ b/src/p4p/client/asyncio.py
@@ -401,6 +401,7 @@ async def _handle(self):
                         if self._notify_disconnect:
                             E = Finished()
                             await self._cb(E)
+                        break  # queue drained; do not loop back and pop() from None
 
 
         except asyncio.CancelledError: