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

Exponential backoff for ``attempt`` (1-indexed), capped at ``cap``.

The chain state after stream A's chainable refusal. `body` is the original request params (pre-pin) — the base every hop patches; `in

Close the response and release the connection. Automatically called if the response body is read to completion.

Close the response and release the connection. Automatically called if the response body is read to completion.

Close the owned ``httpx.Client`` if we created one.

Close the underlying ``httpx.Client`` if we created it.

The accumulated content blocks, in start order.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new client instance re-using the same options given to the current client with optional overriding.

Create a new client instance re-using the same options given to the current client with optional overriding.

Cancel the idle countdown; only signals on an actual transition.

Execute a memory command and return the result. This method dispatches to the appropriate handler method based on the command type (v

Given a type like `Stream[T]`, returns the generic type variable `T`. This also handles the case where a concrete subclass is given, e.g. ```

Process one event, returning the frames to forward for it.

The outcome once the hop's stream is fully consumed (or cut early).

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

Get the helper name from an object, if any.

Pause the countdown while a gated call is held or in flight.

The hop's request body: the entry applied as a patch against the ORIGINAL request params (never a previous hop's patched body), extended

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`

Given an iterator that yields raw binary data, iterate over it & yield every event encountered

Uniform random delay in ``[low, high)`` — spreads out retry storms.

Read and decode the JSON response content.

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``.

Call ``tool`` with ``input``, awaiting the result if the tool is async. Sync tools run on a worker thread. If the caller cancels (for example on

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

Return a valid access token, loading ADC / refreshing as needed. Blocking.

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

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