Convert `(lang, text)` runs to the parallel `SpeechData` field pair, or `(None, None)` when empty.

Build a mock JobContext with the fields that agent_session.start() accesses.

Minimal AudioRecognition wired for the VAD-silence validation — no tasks.

Patch get_job_context and optionally RecorderIO.

Render a template: callables receive ``args``; strings use ``str.format(**args)``.

Report connection timing as a RealtimeModelMetrics event with zero usage.

forcefully kill the process

Graph with fake LLM that streams AIMessageChunk tokens.

Unblock any waiting consumer and mark as closed.

Indicates whether the run has finished processing all events.

Create a LLM instance from a model string

Group chat items (messages, function calls, and function outputs) into coherent groups based on their item IDs and call IDs. Each group will

Interrupt the current speech generation. Returns: An asyncio.Future that completes when the interruption is fully processed

Parse a raw JSON tool-call arguments string into a dict. First tries strict parsing; if the JSON is malformed (common with smaller / open-wei

Pop an item from the dictionary if it satisfies the predicate. Args: predicate: The predicate to check if the value satisfies.

Push audio frame for syllable rate detection

Update the value of a key with the given keyword arguments. Only update the value if the field value is not None and the field exists on the v

Write data to the buffer from a writer thread.

Create a new instance of MistralAI LLM. Uses the Mistral Conversations API, which supports both function tools and provider

Call _upload_session_report with sensible defaults.

Compute the end-of-turn timing metrics from the captured turn anchors. ``last_speaking_time`` is the internal ``_last_speaking_time`` anchor (rep

Execute the referenced tool locally and queue results.

Build a ChatContext with messages of the given roles.

Create a minimal mock SessionReport for upload tests.

Construct a minimal SpeechStream and collect its emitted events. Returns ``(stream_instance, captured_events)`` where each event sent via ``s

Patch OTel logger provider and AccessToken. Yields the mock logger for assertions.

Read a single character from standard input on POSIX systems. This function blocks until a character is available. It uses ``termios`` to di

Normalize a spoken room number ("304") to its id and require it exists.

Reset relevant states for adaptive interruption detection.