Frames still owed when the stream ends without a chainable refusal.

Gets the proxy mappings based on environment variables. We use our own logic to parse these variables, as HTTPX doesn’t allow full config

Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating se

The hop's request body: the refused request's, with the entry's overrides merged over it and extended by the continuation. The server

Returns whether or not the given type is either a `BaseModel` or a union of `BaseModel`

If the given type is `typing.Iterable[T]`

TypeGuard for determining whether or not the given type is a subclass of `Stream` / `AsyncStream`

Note: these endpoints are called automatically by the pre-built environment worker provided in the SDKs and CLI, for orchestrating se

Queue the reached hop's `fallback` seam block at the next monotonic index. Queued seams are flushed by the hop reader once output reaches the

Iterate the raw Server-Sent Events from `response`, before any JSON parsing or event-name filtering. This reads the response body dir

ctor arg → ``ANTHROPIC_IDENTITY_TOKEN_FILE`` → ``None``.

Get a specific model. The Models API response can be used to determine information about a specific model or resolve a model

Degrade to the suppressed refusal when every remaining entry failed over HTTP: replay its message_delta verbatim — `recommended_model`

Higher order function that takes one of our bound API methods and an `APIResponse` class and wraps the method to support returning the given respo

Higher order function that takes one of our bound API methods and an `APIResponse` class and wraps the method to support streaming and returning t

Index ``tools`` by their ``name`` for O(1) dispatch lookup. On a duplicate name the later tool wins, matching a plain dict comprehension.

Strict validation that the given value matches the expected type

Warn that an ``ANTHROPIC_API_KEY`` / ``ANTHROPIC_AUTH_TOKEN`` from the environment is shadowing the SDK's profile / federation auto-discovery.

Warn that an explicit ``api_key=`` / ``auth_token=`` argument shadows an explicit ``credentials=`` provider passed to the same constructor or

Helper method that returns the current proxy, typed as the loaded object

Construct a new synchronous Anthropic client instance. Credentials are resolved in the following order (first match wins): 1. Explic

Async version of :func:`_force_stop_quietly`.

Given an iterator that yields raw binary data, iterate over it and yield individual SSE chunks

Append `addition` to a comma-separated header value, skipping tokens that are already present so the same helper isn't recorded twice. Values

Apply a content_block_delta to the accumulating block at `index`.

Fill `None` fields on `primary` from `fallback`.

Build a :class:`CredentialResult` for the env-var federation path (step 4 in the precedence spec). Returns ``None`` if the required trio isn't

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the middleware invocation chain. The chain only depends on the immutable `self._middleware` tuple so it is built once at constr

Build the result-event params matching ``ev``'s tool-call kind. A custom tool call (``agent.custom_tool_use``) is answered with a ``user.cust

Call the provider, retrying once on a 401 from the token endpoint.

Interactive-login profile. With a ``client_id`` in the auth block, we run the refresh_token grant on expiry; without one, we treat the