fix(client): close streams without requiring full consumption

Co-Authored-By: fede-kamel

Author: stainless-app[bot]

src/anthropic/_streaming.py

@@ -113,9 +113,8 @@ def __stream__(self) -> Iterator[_T]:
                     response=self.response,
                 )
 
-        # Ensure the entire stream is consumed
-        for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        response.close()
 
     def __enter__(self) -> Self:
         return self
@@ -231,9 +230,8 @@ async def __stream__(self) -> AsyncIterator[_T]:
                     response=self.response,
                 )
 
-        # Ensure the entire stream is consumed
-        async for _sse in iterator:
-            ...
+        # As we might not fully consume the response stream, we need to close it explicitly
+        await response.aclose()
 
     async def __aenter__(self) -> Self:
         return self