Struct AgentSession 

pub struct AgentSession { /* private fields */ }

Intercepting wrapper around a SessionWriter.

Adds input fan-out, middleware hooks, and state tracking without introducing a second queue (avoids double-queuing).

Implementations

impl AgentSession

pub fn new(session: SessionHandle) -> Self

Create a new AgentSession wrapping a SessionHandle.

pub fn from_writer( writer: Arc<dyn SessionWriter>, event_tx: Sender<SessionEvent>, ) -> Self

Create from a trait-object writer (enables mock testing and middleware injection).

pub async fn send_audio(&self, data: impl Into<Bytes>) -> Result<(), AgentError>

Send audio data. Fans out to input-streaming tools ONLY if listeners exist.

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

Send a text message.

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

Send tool responses.

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

Send client content (conversation history or context injection).

pub async fn send_video( &self, jpeg_data: impl Into<Bytes>, ) -> Result<(), AgentError>

Send video/image data (raw JPEG bytes).

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

Update the system instruction mid-session.

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

Signal activity start (user started speaking).

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

Signal activity end (user stopped speaking).

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

Gracefully disconnect.

pub fn subscribe_input(&self) -> Receiver<InputEvent>

Subscribe to input events (for input-streaming tools).

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

Subscribe to session events.

pub fn writer(&self) -> &dyn SessionWriter

Access the underlying session writer.

pub fn state(&self) -> &State

Access conversation state.

pub fn input_subscriber_count(&self) -> usize

Number of input-streaming subscribers (for diagnostics).

Trait Implementations

impl Clone for AgentSession

fn clone(&self) -> AgentSession

Returns a duplicate of the value.

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

Performs copy-assignment from source.