Struct SessionStream 

pub struct SessionStream {
    pub session_id: String,
    pub task_id: String,
    pub tag: String,
    pub events: Vec<StreamEvent>,
    pub output_lines: Vec<String>,
    pub status: SessionStatus,
    pub started_at: Instant,
    pub pid: Option<u32>,
    /* private fields */
}

Stream data for a single agent session

Fields

session_id: String

Unique session ID (from harness)

task_id: String

Associated task ID

tag: String

Tag/phase

events: Vec<StreamEvent>

All events received (bounded by MAX_EVENTS)

output_lines: Vec<String>

Rendered output lines for display (bounded by MAX_OUTPUT_LINES)

status: SessionStatus

Current status

started_at: Instant

When the session started

pid: Option<u32>

Process ID (for interruption)

Implementations

impl SessionStream

pub fn new(task_id: &str, tag: &str) -> Self

pub fn push_event(&mut self, event: StreamEvent)

Add an event and update output lines

pub fn tail(&self, n: usize) -> &[String]

Get the last N output lines

pub fn get_all_output(&self) -> Vec<String>

Get all output lines including any partial line in progress

pub fn is_active(&self) -> bool

Check if session is still active

pub fn event_count(&self) -> usize

Get the event count

pub fn line_count(&self) -> usize

Get the output line count

Trait Implementations

impl Debug for SessionStream

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

Formats the value using the given formatter.