private conn and remove shutdown method

aiosonic/__init__.py

@@ -93,7 +93,7 @@ def __init__(self):
         self.raw_headers = []
         self.body = b""
         self.response_initial = {}
-        self.connection = None
+        self._connection = None
         self.chunked = False
         self.compressed = b""
         self.chunks_readed = False
@@ -139,7 +139,7 @@ def _update_cookies(self, header_tuple):
 
     def _set_connection(self, connection: Connection):
         """Set header to response."""
-        self.connection = connection
+        self._connection = connection
 
     @property
     def status_code(self) -> int:
@@ -208,27 +208,27 @@ async def json(self, json_decoder=loads) -> dict:
 
     async def read_chunks(self) -> AsyncIterator[bytes]:
         """Read chunks from chunked response."""
-        if not self.connection:
+        if not self._connection:
             raise ConnectionError("missing connection, possible already read response.")
         try:
             while True and not self.chunks_readed:
-                chunk_size = int((await self.connection.readline()).rstrip(), 16)
+                chunk_size = int((await self._connection.readline()).rstrip(), 16)
                 if not chunk_size:
                     # read last CRLF
-                    await self.connection.readline()
+                    await self._connection.readline()
                     break
-                chunk = await self.connection.readexactly(chunk_size + 2)
+                chunk = await self._connection.readexactly(chunk_size + 2)
                 yield chunk[:-2]
             self.chunks_readed = True
         finally:
             # Ensure the conn get's released
-            self.connection.release()
-            self.connection = None
+            self._connection.release()
+            self._connection = None
 
     def __del__(self):
         # clean it
-        if self.connection:
-            self.connection.ensure_released()
+        if self._connection:
+            self._connection.ensure_released()
 
     def _set_request_meta(self, urlparsed: ParseResult):
         self.request_meta = {"from_path": urlparsed.path or "/"}
@@ -512,11 +512,6 @@ async def __aenter__(self):
     async def __aexit__(self, _exc_type, exc, _tb):  # type: ignore
         if exc:
             raise exc
-        await self.shutdown()
-
-    async def shutdown(self):
-        """Cleanup connections, this method makes client unusable."""
-        await self.connector.cleanup()
 
     async def _request_with_body(
         self,

aiosonic/pools.py

@@ -37,7 +37,7 @@ async def cleanup(self):
 
 
 class SmartPool:
-    """Pool which utilizes alive connections."""
+    """Pool which priorizes the reusage of connections."""
 
     def __init__(self, connector, pool_size, connection_cls):
         self.pool_size = pool_size

tests/test_aiosonic.py

@@ -476,7 +476,7 @@ async def test_get_chunked_response(app, aiohttp_server):
 
     async with aiosonic.HTTPClient() as client:
         res = await client.get(url)
-        assert res.connection
+        assert res._connection
         assert res.status_code == 200
 
         chunks = [b"foo", b"bar"]
@@ -526,7 +526,7 @@ async def test_read_chunks_by_text_method(app, aiohttp_server):
 
     async with aiosonic.HTTPClient() as client:
         res = await client.get(url)
-        assert res.connection
+        assert res._connection
         assert res.status_code == 200
         assert await res.text() == "foobar"
         await server.close()