From df719276d193025337d886a7a6300d8aacb86d63 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Fri, 22 Mar 2019 14:21:21 +0000 Subject: [PATCH] Proper shutdown of TCP connections on ^D --- syndicate/mini/core.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/syndicate/mini/core.py b/syndicate/mini/core.py index 7da9284..18049a5 100644 --- a/syndicate/mini/core.py +++ b/syndicate/mini/core.py @@ -164,7 +164,8 @@ class _StreamConnection(Connection, asyncio.Protocol): def _disconnect(self): if self.stop_signal: - self.stop_signal.set_result(True) + self.stop_signal.get_loop().call_soon_threadsafe( + lambda: self.stop_signal.set_result(True)) async def _create_connection(self, loop): raise Exception('subclassresponsibility')