From 79f433167c7bf7ef850a3adb602521d377dfa752 Mon Sep 17 00:00:00 2001 From: Tony Garnock-Jones Date: Thu, 19 Aug 2021 17:27:33 -0400 Subject: [PATCH] Slightly improve exiting of tcp connections --- syndicate/relay.py | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/syndicate/relay.py b/syndicate/relay.py index 6122301..37a0c0c 100644 --- a/syndicate/relay.py +++ b/syndicate/relay.py @@ -333,8 +333,12 @@ class _StreamTunnelRelay(TunnelRelay, asyncio.Protocol): def _disconnect(self): if self.stop_signal: - self.stop_signal.get_loop().call_soon_threadsafe( - lambda: self.stop_signal.set_result(True)) + def set_stop_signal(): + try: + self.stop_signal.set_result(True) + except: + pass + self.stop_signal.get_loop().call_soon_threadsafe(set_stop_signal) async def _create_connection(self, loop): raise Exception('subclassresponsibility')