ProxyConnector doesn't support keep-alive requests by default startin…

…g from now #368

Add connector.force_close property

CHANGES.txt

@@ -28,6 +28,11 @@ CHANGES
 
 - Add `response_class` parameter to `ws_connect()` #367
 
+- `ProxyConnector` doesn't support keep-alive requests by default
+  starting from now #368
+
+- Add `connector.force_close` property
+
 
 0.15.3 (04-22-2015)
 -------------------

aiohttp/connector.py

@@ -146,6 +146,11 @@ def __del__(self):
                 context['source_traceback'] = self._source_traceback
             self._loop.call_exception_handler(context)
 
+    @property
+    def force_close(self):
+        """Ultimately close connection on releasing."""
+        return self._force_close
+
     def _cleanup(self):
         """Cleanup unused transports."""
         if self._cleanup_handle:
@@ -493,8 +498,9 @@ class ProxyConnector(TCPConnector):
 
     """
 
-    def __init__(self, proxy, *, proxy_auth=None, **kwargs):
-        super().__init__(**kwargs)
+    def __init__(self, proxy, *, proxy_auth=None, force_close=True,
+                 **kwargs):
+        super().__init__(force_close=force_close, **kwargs)
         self._proxy = proxy
         self._proxy_auth = proxy_auth
         assert proxy.startswith('http://'), (

docs/client_reference.rst

@@ -372,6 +372,11 @@ All connector classes should be derived from :class:`BaseConnector`.
 
       Read-only property, ``True`` if connector is closed.
 
+   .. attribute:: force_close
+
+      Read-only property, ``True`` if connector should ultimately
+      close connections on releasing.
+
    .. method:: close()
 
       Close all opened connections.

tests/test_connector.py

@@ -636,6 +636,10 @@ class Req:
 
         self.loop.run_until_complete(go())
 
+    def test_default_force_close(self):
+        connector = aiohttp.BaseConnector(loop=self.loop)
+        self.assertFalse(connector.force_close)
+
 
 class TestHttpClientConnector(unittest.TestCase):
 
@@ -718,6 +722,7 @@ def test_ctor2(self):
                                            loop=self.loop)
 
         self.assertEqual('http://localhost:8118', connector.proxy)
+        self.assertTrue(connector.force_close)
 
     @unittest.mock.patch('aiohttp.connector.ClientRequest')
     def test_connect(self, ClientRequestMock):