Update close method in TcpConnection to use run_coroutine_threadsafe …

…for improved asynchronous handling
Thymis-io · Jan 28, 2025 · 9d0a9a9 · 9d0a9a9
1 parent 0b71285
commit 9d0a9a9
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/http_network_relay/network_relay.py b/http_network_relay/network_relay.py
@@ -97,8 +97,11 @@ def recv(self, size):
             self.recv_buffer = self.recv_buffer[size:]
         return result
 
-    async def close(self):
-        return await self.relay.close_relayed_connection(self.id, self.agent_connection)
+    def close(self):
+        return asyncio.run_coroutine_threadsafe(
+            self.relay.close_relayed_connection(self.id, self.agent_connection),
+            self.loop,
+        )
 
     @property
     def closed(self):