diff --git a/http_network_relay/network_relay.py b/http_network_relay/network_relay.py index 2ffe4a8..96be278 100644 --- 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):