Struct ManagedSession 

pub struct ManagedSession {
    pub session: Session,
    pub command_tx: Sender<AppCommand>,
    pub event_rx: Option<Receiver<AppEvent>>,
    pub subscriber_count: usize,
    pub last_activity: DateTime<Utc>,
    pub app_task_handle: JoinHandle<()>,
    pub event_task_handle: JoinHandle<()>,
}

A managed session contains both the session state and the App instance

Fields

session: Session

The session data

command_tx: Sender<AppCommand>

Command sender for the App

event_rx: Option<Receiver<AppEvent>>

Event receiver from the App (for external consumers like TUI)

subscriber_count: usize

Event subscriber count

last_activity: DateTime<Utc>

Last activity timestamp for cleanup

app_task_handle: JoinHandle<()>

Handle to the app actor loop task

event_task_handle: JoinHandle<()>

Handle to the event translation task

Implementations

impl ManagedSession

pub async fn new( session: Session, app_config: AppConfig, store: Arc<dyn SessionStore>, default_model: ModelId, conversation: Option<Conversation>, ) -> Result<Self>

Create a new managed session

pub fn take_event_rx(&mut self) -> Option<Receiver<AppEvent>>

Take the event receiver (can only be called once)

pub fn touch(&mut self)

Update last activity timestamp

pub fn is_inactive(&self, max_idle_time: Duration) -> bool

Check if session is inactive (no subscribers and old)

pub async fn shutdown(self)

Shutdown the session gracefully