Return a fully-populated ``AsyncToolOptions`` with defaults filled in for absent keys.

Strip the RIFF/WAV header if present, returning only PCM samples.

Capture an audio frame for playback, frames can be pushed faster than real-time

Collect all content chunks from a stream.

Disconnect from service

Mark the current text segment as complete (e.g LLM generation is complete)

Clear all existing connections. Marks all current connections to be closed during the next drain cycle.

Return only chat messages, ignoring function calls, outputs, and other events.

Add audio data to the buffer and retrieve fixed-size frames. Parameters: data (bytes): The incoming audio data to buffer

Set a value for a key if it doesn't exist, or update it if it does. Args: key: The key to set or update. factory: The

Return the English language name (e.g. ``'english'``), or ``None`` if unknown.

Args: voice (str, optional): Voice. model (TTSModels | str, optional): TTS model to use. language (str, o

Returns a participant that matches the given identity. If identity is None, the first participant that joins the room will be returne

Helper that closes all channels of the active generation.

Call the real _detach_reusable_resources, return stt_pipeline.

Drive `_recv_messages_task` with canned messages, return collected events. Sets `stream._ws = None` after collecting events so the plugin's outer

Drive a task to completion across multiple turns and return the matching calls. The LLM may respond conversationally before calling a completion

Get the current activity context for this task (internal)

Build a minimal RunContext — only what the executor and update() actually read.

Helper method to process a list of (text, speaker_id) fragments.

_queue_msg raises aio.ChanClosed when the worker is closing/closed

True (and records the emission) if the cooldown elapsed or usage grew by _MEMORY_WARN_RESET_DELTA_MB since the last warning.

Return a copy whose ``str`` value is the correct variant for *modality*. Both ``_audio_variant`` and ``_text_variant`` are preserved so this

Close the HTTP session if we own it.

Number of logical CPUs. Returns a float to allow for fractional CPUs (in the case of cgroups).

Deletes the room and disconnects all participants.

Force callback to be called with current total if non-zero

Verify this event is an agent handoff. Args: new_agent_type (type, optional): Expected new agent class. Returns

Load and initialize the Silero VAD model. This method loads the ONNX model and prepares it for inference. When options are not provi

Read data from the buffer in a reader thread.

Resolve an environment variable from a list of potential sources. Args: val: The value to resolve. *env_vars: The environmen

Shift the buffer to the left by the given size. Args: size: The size to shift the buffer by.

Arm the overall detection-timeout budget.

Bind this toolset to a scope. ``activity=None`` makes it session-scoped (replies survive handoff); otherwise replies stay with ``activity``'s

Extract provider and model from metrics metadata.

Format a ChatContext into a string.