Struct SessionManager 

pub struct SessionManager { /* private fields */ }

Agent session manager.

Handles session lifecycle and communication channels.

Implementations

impl SessionManager

pub fn new(event_tx: Sender<AgentEvent>) -> Self

Create a new session manager with event sender.

pub fn with_channels( event_tx: Sender<AgentEvent>, ask_rx: Option<Receiver<String>>, ) -> Self

Create a session manager with all channels.

pub fn with_pending_input( event_tx: Sender<AgentEvent>, pending_input_rx: Option<Receiver<String>>, ) -> Self

Create a session manager with pending input channel.

pub fn with_all_channels( event_tx: Sender<AgentEvent>, ask_rx: Option<Receiver<String>>, pending_input_rx: Option<Receiver<String>>, ) -> Self

Create a session manager with all channels including pending input.

pub fn emit(&self, event: AgentEvent) -> Result<()>

Emit an agent event.

pub fn is_cancelled(&self) -> bool

Check if session is cancelled.

pub fn set_cancel_token(&mut self, token: CancellationToken)

Set cancellation token.

pub fn cancel_token(&self) -> Option<&CancellationToken>

Get cancellation token.

pub fn set_ask_channel(&mut self, rx: Receiver<String>)

Set ask response channel.

pub fn has_ask_channel(&self) -> bool

Check if ask response channel is available (no mutable borrow needed).

pub fn ask_rx(&mut self) -> Option<&mut Receiver<String>>

Get ask response channel.

pub fn set_pending_input_channel(&mut self, rx: Receiver<String>)

Set pending input channel.

pub fn pending_input_rx(&mut self) -> Option<&mut Receiver<String>>

Get pending input channel.

pub fn drain_pending_inputs(&mut self) -> Vec<String>

Drain pending inputs from the channel.

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

Get event sender (for cloning).

pub fn clear(&mut self)

Clear session state (reset cancellation).