Create a stream and cancel its live receive loop so we can drive methods directly. The stream's __init__ spawns a background task that runs the f

Create a mock aiohttp.ClientSession with async post.

Build an AudioRecognition stub with just the attributes ``push_audio`` reads.

Generate a valid PCM16 WAV file in memory.

Capture server-assigned request_id once it is available.

Diagnostic context for the memory logs: tells a process that started heavy from one that grew over time (uptime, baseline RSS, growth).

Pick a creation timestamp anchored to the most recent user-final if fresh. Returns the last user-final timestamp if it exists and is recent;

Report connection timing as an STTMetrics event with zero usage.

Extract a required argument, raising ValueError if missing.

Return the effective threshold for observability only. Precedence: user override, then server default; None when neither is known.

Accept a prediction from a transport. Stale response is ignored.

Update the chat context with the latest ASR text while guarding against model limitations: a) 40 total messages limit

Wait for the stream's background task to complete and return the exception.

Wrap a session object in the appropriate event type. For Azure, converts the new-style session to the old flat format and returns a d

Close the connection, failing any remaining streams.

strict mode tool description

Clean up processor session resources (public method for backward compatibility).

Queue a close message for a context (removes from pool).

Single source of truth for booking math: returns (subtotal, taxes, total, line_items). Used by book_room, update_booking, and the seed script so n

Returns True if the sound has finished playing.

Signal that no more data will be written.

Filter out markdown symbols from the text.

Returns the index to insert an item by creation time. Iterates in reverse, assuming items are sorted by `created_at`. Finds

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

Atomically read the current value and reset it.

Time taken to perform the inference from the model side, in seconds.

The conservative estimated probability of the interruption event.

RTT (Round Trip Time) time taken to perform the inference, in seconds.

Return True if any tool (or nested toolset tool) has ``ToolFlag.CANCELLABLE``.

Return True if `other` has the same sequence of items with matching essential fields (IDs, types, and payload) as this context.

Add messages from `other_chat_ctx` into this one, avoiding duplicates, and keep items sorted by created_at.

Notify the sender that playback has finished

Add a value to the accumulator

Push some audio frame to be analyzed

Push audio to be recognized