Receive transcription messages, handle tokens, errors, and dispatch events.

Remove a context and signal that capacity is available.

Run mode the user asked for via flags/env, before the xdist override: off/default/all.

Check if model requires thought_signature handling for multi-turn function calling. Gemini 2.5+ models require thought signatures to be stored fr

Internal method to send text message to Nova Sonic 2.0. Args: text (str): The text message to send to the model. inte

Test if the event should be held until the ignore_user_transcript_until timestamp.

Remove the buffering handler without replaying.

Track a fire-and-forget task so its exceptions are surfaced instead of swallowed. Callers may still await the returned task to handle errors

Validate language code for a given model. Args: model: The Sarvam model name. language: The requested language code (may be None)

Validate and resolve mode for a given model. Args: model: The Sarvam model name. mode: The requested mode (may be None to use def

Logs a warning when arguments are unexpected. This is not necessarily an error since the API may support languages in the future.

Read a single UTF‑16 code unit from standard input on Windows systems. This function blocks until a character is available. It wraps ``msvcr

True when pytest-xdist is in play -- on the controller *and* inside each worker. xdist splits a run by *item*, which would scatter a concurrent g

Accept the job request, and start the job if the LiveKit SFU assigns the job to our worker.

Get accumulated speaking units up to the given timestamp.

Close the STT, and every stream/requests associated with it

Decode the audio file into rtc.AudioFrame instances and yield them as an async iterable. Args: file_path (str): The path to the audio

Graph with StreamWriter that emits custom payloads.

Close the current inference request (new speech, turn boundary, prediction timeout, mode change) and fall back if needed.

Convert mid-conversation system messages to the given role to preserve their position. The first system/developer message is kept as the base pre

Order-invariant denylist diff of two hotel DBs. Empty list == states match.

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

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

Total time from the onset of the speech to the final prediction, in seconds.

Get names of all function and raw function tools in the list, unwrapping tool sets.

Open the Bedrock bidirectional stream and spawn background worker tasks. This coroutine is idempotent and can be invoked again when recoverab

Construct a cloud-mode stream with a controlled transport. Returns the stream, the fake ws, and the transport so callers can read post-connec

Plays an audio once or in a loop. Args: audio (Union[AudioSource, AudioConfig, List[AudioConfig]]): The

Public method that calls _process (for backward compatibility).

Creates a TaskGroup that collects user information

Add a value to the accumulator

Push transcript text to the AMD classifier.

Release a reference to the SDK (destroys if last reference). Call this when destroying a filter instance. The SDK will be cleaned up