Fix ChainProxyConnector

aiohttp_socks/connector.py

@@ -123,6 +123,8 @@ def __init__(self, proxy_infos: Iterable[ProxyInfo], **kwargs):
 
         self._proxy_infos = proxy_infos
 
+        self._streams = []
+
     # noinspection PyMethodOverriding
     async def _wrap_create_connection(self, protocol_factory, host, port, *, ssl, **kwargs):
         proxies = []
@@ -152,6 +154,14 @@ async def _wrap_create_connection(self, protocol_factory, host, port, *, ssl, **
             timeout=connect_timeout,
         )
 
+        # Fix issue https://github.com/romis2012/aiohttp-socks/issues/27
+        # On Python 3.11.5
+        # We need to keep references to the stream.reader/stream.writer so that they
+        # are not garbage collected and closed while we're still using them.
+        # See StreamWriter.__del__ method (was added in Python 3.11.5)
+        self._streams.append(stream)
+        #
+
         transport: BaseTransport = stream.writer.transport
         protocol: ResponseHandler = protocol_factory()