chore(internal): options updates (#248)

src/anthropic/_base_client.py

@@ -863,7 +863,7 @@ def _request(
         self._prepare_request(request)
 
         try:
-            response = self._client.send(request, auth=self.custom_auth, stream=stream)
+            response = self._client.send(request, auth=self.custom_auth, stream=stream or options.stream or False)
             log.debug(
                 'HTTP Request: %s %s "%i %s"', request.method, request.url, response.status_code, response.reason_phrase
             )
@@ -1304,7 +1304,7 @@ async def _request(
         await self._prepare_request(request)
 
         try:
-            response = await self._client.send(request, auth=self.custom_auth, stream=stream)
+            response = await self._client.send(request, auth=self.custom_auth, stream=stream or options.stream or False)
             log.debug(
                 'HTTP Request: %s %s "%i %s"', request.method, request.url, response.status_code, response.reason_phrase
             )
@@ -1541,6 +1541,7 @@ def make_request_options(
     idempotency_key: str | None = None,
     timeout: float | httpx.Timeout | None | NotGiven = NOT_GIVEN,
     post_parser: PostParser | NotGiven = NOT_GIVEN,
+    stream: bool | None = None,
 ) -> RequestOptions:
     """Create a dict of type RequestOptions without keys of NotGiven values."""
     options: RequestOptions = {}
@@ -1562,6 +1563,9 @@ def make_request_options(
     if idempotency_key is not None:
         options["idempotency_key"] = idempotency_key
 
+    if stream is not None:
+        options["stream"] = stream
+
     if is_given(post_parser):
         # internal
         options["post_parser"] = post_parser  # type: ignore

src/anthropic/_models.py

@@ -403,6 +403,7 @@ class FinalRequestOptionsInput(TypedDict, total=False):
     params: Query
     headers: Headers
     max_retries: int
+    stream: bool | None
     timeout: float | Timeout | None
     files: HttpxRequestFiles | None
     idempotency_key: str
@@ -420,6 +421,7 @@ class FinalRequestOptions(pydantic.BaseModel):
     timeout: Union[float, Timeout, None, NotGiven] = NotGiven()
     files: Union[HttpxRequestFiles, None] = None
     idempotency_key: Union[str, None] = None
+    stream: Union[bool, None] = None
     post_parser: Union[Callable[[Any], Any], NotGiven] = NotGiven()
 
     # It should be noted that we cannot use `json` here as that would override

src/anthropic/_types.py

@@ -257,6 +257,7 @@ async def aclose(self) -> None:
 class RequestOptions(TypedDict, total=False):
     headers: Headers
     max_retries: int
+    stream: bool
     timeout: float | Timeout | None
     params: Query
     extra_json: AnyMapping