fix: address review feedback from karpetrosyan

- Replace decoder.close() with response.close() in sync stream
- Replace decoder.close() with response.aclose() in async stream
- Standardize comments between sync and async implementations

Addresses feedback from PR anthropics#993:
- SSEDecoder doesn't have a close method, properly close httpx response instead
- Ensure consistent comments between sync/async versions

Author: fede-kamel

src/anthropic/_streaming.py

@@ -120,10 +120,9 @@ def __stream__(self) -> Iterator[_T]:
                     response=self.response,
                 )
 
-        # Explicitly closes decoder resources if available
+        # Explicitly close the response to release the connection
         # Immediately releases connection instead of consuming remaining stream
-        if hasattr(self._decoder, "close"):
-            self._decoder.close()  # Properly closes decoder resources without unnecessary iteration
+        self.response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -206,7 +205,7 @@ async def __stream__(self) -> AsyncIterator[_T]:
         async for sse in iterator:
             if sse.event == "completion":
                 yield process_data(data=sse.json(), cast_to=cast_to, response=response)
-            # same O(1) lookup for consistency between sync/async versions
+            # Single, fast membership test instead of multiple string comparisons
             if sse.event in MESSAGE_EVENTS:
                 data = sse.json()
                 if is_dict(data) and "type" not in data:
@@ -232,9 +231,9 @@ async def __stream__(self) -> AsyncIterator[_T]:
                     response=self.response,
                 )
 
+        # Explicitly close the response to release the connection
         # Immediately releases connection instead of consuming remaining stream
-        if hasattr(self._decoder, "close"):
-            self._decoder.close()  # Properly closes decoder resources without unnecessary iteration
+        await self.response.aclose()
 
     async def __aenter__(self) -> Self:
         return self