Struct LiveSession 

pub struct LiveSession { /* private fields */ }

An active primary or forked Live WebSocket session.

The model advances only while input audio is streaming in real time. Keep sending audio frames (silence is acceptable) even when injecting commentary or instructions; otherwise the injection can remain incomplete until close.

Implementations

impl LiveSession

pub fn session_id(&self) -> &str

Returns the opaque Live session identifier.

pub fn started(&self) -> &SessionResource

Returns the full resolved session from session.started.

pub fn split(self) -> (LiveSender, LiveReceiver)

Splits the session for concurrent sending and receiving.

pub async fn send(&self, event: ClientEvent) -> Result<()>

Sends a raw typed client event.

pub async fn recv(&mut self) -> Result<Option<ServerEvent>>

Receives the next typed server event.

pub async fn append_audio(&self, base64: &str) -> Result<()>

Appends base64-encoded audio input.

pub async fn append_audio_bytes(&self, audio: &[u8]) -> Result<()>

Base64-encodes and appends raw audio input.

pub async fn mute(&self) -> Result<()>

Mutes input audio.

pub async fn unmute(&self) -> Result<()>

Unmutes input audio.

pub async fn append_instructions( &self, content: impl Into<String>, delegation_id: Option<&str>, ) -> Result<()>

Appends system-level instructions.

pub async fn append_thinking( &self, content: impl Into<String>, delegation_id: Option<&str>, ) -> Result<()>

Appends silent reasoning context.

pub async fn append_commentary( &self, content: impl Into<String>, delegation_id: Option<&str>, ) -> Result<()>

Appends content that the model should speak.

pub async fn create_response_item(&self, item: Value) -> Result<()>

Adds an input item to a Responses delegation.

pub async fn submit_function_output( &self, call_id: impl Into<String>, output: impl Into<String>, ) -> Result<()>

Submits a function-call result to a Responses delegation.

pub async fn create_response(&self) -> Result<()>

Requests that a Responses delegation continue generating.

pub async fn update_delegation(&self, delegation: Delegation) -> Result<()>

Updates settings within the current delegation type.

pub async fn close(self) -> Result<Option<SessionClosedEvent>>

Sends session.close, waits for session.closed, and closes the socket.