From 3ac27c612c8c19a368096d68d153d30d4278da3e Mon Sep 17 00:00:00 2001
From: jcass77 <john.cass77@gmail.com>
Date: Wed, 5 Aug 2020 09:33:14 +0200
Subject: [PATCH] wip: Resolve process hangs during shutdown.

---
 wtfix/apps/sessions.py | 6 ++----
 1 file changed, 2 insertions(+), 4 deletions(-)

diff --git a/wtfix/apps/sessions.py b/wtfix/apps/sessions.py
index c65f1ea..4d0df3a 100644
--- a/wtfix/apps/sessions.py
+++ b/wtfix/apps/sessions.py
@@ -228,15 +228,13 @@ async def listen(self):
                         data
                     )  # Process logout message in the pipeline as per normal
 
-                    raise e
-
                 else:
                     logger.error(
                         f"{self.name}: Unexpected EOF waiting for next chunk of partial data "
                         f"'{utils.decode(e.partial)}' ({e})."
                     )
 
-                    raise e
+                    asyncio.create_task(self.pipeline.stop())
 
             except LimitOverrunError as e:
                 # Buffer limit reached before a complete message could be read - abort!
@@ -244,7 +242,7 @@ async def listen(self):
                     f"{self.name}: Stream reader buffer limit exceeded! ({e})."
                 )
 
-                raise e
+                asyncio.create_task(self.pipeline.stop())
 
     async def on_send(self, message):
         """