Get an available connection or create a new one if needed. Returns: An active connection object

Discard all buffered data and reset progressive frame sizing. After clearing, the next :meth:`push` will start from the initial (smal

Add a tag to the session with optional structured metadata. Args: tag: The tag string in "key:value" format (e.g., "voicemail:tru

Mark the end of input, no more audio will be pushed

Create a text transform that replaces words with new words. Buffers enough text to handle terms that might be split across token boundaries d

Build consistent logging context.

Push a progress update into the conversation. The first update releases control to the LLM with ``message`` as the tool's synthetic r

Formats a log record and serializes to json

Connect to the room. This method should be called only once. Args: encryption: End-to-end encryption options. If provided, the Ag

Run AMD and return the result. While executing, speech playout authorization is locked. Once the result is available, authorization i

Check if the event timestamp is within the target timestamp +/- max_abs_diff. The event timestamp is scaled by the speed factor. ``max_a

Insert an item or list of items into the chat context by creation time.

The text variant of the instructions. Falls back to the audio variant when no text variant was provided.

Verify this event is a message from the given role. Args: role (ChatRole, optional): Expected sender role. Retu

Push some text to be synthesized

Flush the buffer and retrieve any remaining audio data as a frame. Returns: list[rtc.AudioFrame]: A list containing any

Generate a reply for the agent to speak to the user. Args: user_input (NotGivenOr[str | llm.ChatMessage], optional): The user's i

Build consistent logging context.

Push an audio frame to the buffer. Args: frame: The audio frame to push. Returns: The number of samples writ

Wire enough of AudioRecognition to drive `_run_eou_detection` against a fake audio turn-detector — used by the speaking-guard tests.

Add a callback to be called when the job is shutting down. Optionally the callback can take a single argument, the shutdown reason.