Streamed-PCM source track with a thread-safe push/clear interface. Backs an :class:`AudioSourceTrack` with an internal :class:`av.AudioFifo`

Watches the AppSession and runs ``callback`` when the resource it guards is no longer needed for this session. Two triggers, both polled on a

Stand-in for `streamlit.runtime.app_session.AppSession`. Defined as a regular class (not SimpleNamespace) so it can be the target of `weakref

Yields a fixed sequence of frames, then ends.

SafeSessionState-like test double. Streamlit's production ScriptRunContext exposes SafeSessionState, which supports item access but not mappi

Owns the OpenAI Realtime WebSocket and the I/O bridges. Runs the session on a private asyncio loop in a background thread so a slow event-rec

Replaces every frame with a constant-value frame.

A base class for audio processors.

No-drop sink that dispatches each input frame to a user callback. The callback runs on aiortc's event loop. If the callback is slow it backpr

A consumer-side counterpart to a media source track. A ``MediaSink`` is attached to one input ``MediaStreamTrack`` via ``addTrack`` and pulle

Async (background-thread) processor wrapper.