wip: Resolve process hangs during shutdown.

jcass77 · Aug 5, 2020 · 53c3006 · 53c3006
1 parent 3ac27c6
commit 53c3006
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/wtfix/apps/sessions.py b/wtfix/apps/sessions.py
@@ -234,15 +234,19 @@ async def listen(self):
                         f"'{utils.decode(e.partial)}' ({e})."
                     )
 
+                    # Stop listening for messages
                     asyncio.create_task(self.pipeline.stop())
+                    break
 
             except LimitOverrunError as e:
                 # Buffer limit reached before a complete message could be read - abort!
                 logger.error(
                     f"{self.name}: Stream reader buffer limit exceeded! ({e})."
                 )
 
+                # Stop listening for messages
                 asyncio.create_task(self.pipeline.stop())
+                break
 
     async def on_send(self, message):
         """