Send frames to the pipeline.

Send HTTP request with retry logic. Handles both JSON and FormData request formats with configurable retry behavior. Args:

Send tool_result back to Bedrock, grouped under tool_use_id.

Start IVR detection on this session. This method injects the DTMF tool and enables loop/silence detection, allowing the agent to navi

Spawn a background task that keeps ``ws`` alive with periodic pings. Idempotent: if a live keepalive task is already registered for ``ws``

Cancel the keepalive task associated with ``ws`` (if any).

Apply in-place edits of a ``flatten()`` list, preserving Toolset grouping. Added tools become top-level entries; removed tools are dropped fr

Connect a room, start waiting, disconnect, and assert RuntimeError.

Return timed words and the remaining text

Try to generate with the given LLM. Args: llm: The LLM instance to generate with check_recovery: When True,

Record that ``speech_handle`` is paused. If already paused for this handle, only ``timeout`` is updated — the ``agent_state`` capture

The virtual-time loop driving the current call, or None. Returns None when there is no running loop (e.g. a background thread such as the OpenTel

Judge that evaluates factual accuracy of information provided. Focuses on grounding - responses must be supported by function call outputs. C

attempt to gracefully close the job. warn if it takes too long to close (in the threaded executor, the job can't be "killed")

attempt to gracefully close the supervised process

Close the connection and clean up

Close all streams and the persistent connection.

Close the stream and clean up resources.

Close all active streams and connections.

Acquire a reference to the SDK (initializes if needed). Call this when creating a filter instance. The SDK will be initialized on the

Adds an entrypoint function to be run when a participant joins the room. In cases where the participant has already joined, the entrypoint wil