Struct SessionHandle 

pub struct SessionHandle {
    pub command_tx: Sender<SessionCommand>,
    pub state: Arc<SessionState>,
    /* private fields */
}

The public API surface for a Gemini Live session.

Cheaply cloneable (wraps Arc). Provides methods to send commands, subscribe to events, and observe session state.

Fields

command_tx: Sender<SessionCommand>

Channel for sending commands to the transport layer.

state: Arc<SessionState>

Shared session state.

Implementations

impl SessionHandle

pub fn new( command_tx: Sender<SessionCommand>, event_tx: Sender<SessionEvent>, state: Arc<SessionState>, phase_rx: Receiver<SessionPhase>, ) -> Self

Create a new session handle from its components.

pub fn set_task(&self, handle: JoinHandle<()>)

Store the connection loop task handle.

Called by the transport layer after spawning the connection loop.

pub async fn join(&self) -> Result<(), JoinError>

Wait for the session connection loop to complete.

Returns Ok(()) when the session disconnects normally. Returns Err if the connection task panicked.

Only the first call across all clones actually awaits the task; subsequent calls return Ok(()) immediately.

pub fn subscribe(&self) -> Receiver<SessionEvent>

Subscribe to session events.

pub fn event_sender(&self) -> &Sender<SessionEvent>

Get the event sender (for internal use by transport).

pub fn phase(&self) -> SessionPhase

Current session phase.

pub fn session_id(&self) -> &str

Session ID.

pub async fn wait_for_phase(&self, target: SessionPhase)

Wait for the session to reach a specific phase.

pub async fn send_audio(&self, data: Vec<u8>) -> Result<(), SessionError>

Send audio data (raw PCM16 bytes).

pub async fn send_text( &self, text: impl Into<String>, ) -> Result<(), SessionError>

Send a text message.

pub async fn send_tool_response( &self, responses: Vec<FunctionResponse>, ) -> Result<(), SessionError>

Send tool responses.

pub async fn send_video(&self, jpeg_data: Vec<u8>) -> Result<(), SessionError>

Send a video/image frame (raw JPEG bytes).

pub async fn update_instruction( &self, instruction: impl Into<String>, ) -> Result<(), SessionError>

Update the system instruction mid-session.

pub async fn signal_activity_start(&self) -> Result<(), SessionError>

Signal activity start (user started speaking).

pub async fn signal_activity_end(&self) -> Result<(), SessionError>

Signal activity end (user stopped speaking).

pub async fn send_client_content( &self, turns: Vec<Content>, turn_complete: bool, ) -> Result<(), SessionError>

Send client content (turns + turn_complete flag). Used for injecting conversation history, context, or multi-turn text.

pub async fn disconnect(&self) -> Result<(), SessionError>

Gracefully disconnect the session.

Trait Implementations

impl Clone for SessionHandle

fn clone(&self) -> SessionHandle

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SessionHandle

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl SessionReader for SessionHandle

fn subscribe(&self) -> Receiver<SessionEvent>

Subscribe to the session event broadcast stream.

fn phase(&self) -> SessionPhase

Returns the current session phase.

fn session_id(&self) -> &str

Returns the unique session ID.

impl SessionWriter for SessionHandle

fn send_audio<'life0, 'async_trait>( &'life0 self, data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send raw PCM16 audio bytes.

fn send_text<'life0, 'async_trait>( &'life0 self, text: String, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a text message.

fn send_tool_response<'life0, 'async_trait>( &'life0 self, responses: Vec<FunctionResponse>, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send tool/function call responses back to the model.

fn send_client_content<'life0, 'async_trait>( &'life0 self, turns: Vec<Content>, turn_complete: bool, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send client content (conversation history or context).

fn send_video<'life0, 'async_trait>( &'life0 self, jpeg_data: Vec<u8>, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Send a video/image frame (raw JPEG bytes).

fn update_instruction<'life0, 'async_trait>( &'life0 self, instruction: String, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Update the system instruction mid-session.

fn signal_activity_start<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that user speech activity has started.

fn signal_activity_end<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Signal that user speech activity has ended.

fn disconnect<'life0, 'async_trait>( &'life0 self, ) -> Pin<Box<dyn Future<Output = Result<(), SessionError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Gracefully disconnect the session.