Struct TurnStreamCollector 

pub struct TurnStreamCollector { /* private fields */ }

Shared turn stream collector engine used by runtime prompt and artifact execution flows. It filters by (thread_id, turn_id), accumulates assistant text, and reports terminal events.

Implementations

impl TurnStreamCollector

pub fn new(thread_id: &str, turn_id: &str) -> Self

Create collector bound to one target turn.

pub fn push_envelope( &mut self, envelope: &Envelope, ) -> Option<TurnTerminalEvent>

Consume one envelope. Returns terminal event when this envelope closes the target turn.

pub fn is_target_envelope(&self, envelope: &Envelope) -> bool

Whether one envelope belongs to this collector turn target.

pub fn matching_turn_events(&self) -> usize

Number of consumed envelopes that matched the target turn.

pub fn assistant_text(&self) -> &str

Borrow current collected assistant text.

pub fn into_assistant_text(self) -> String

Take ownership of collected assistant text.

Trait Implementations

impl Clone for TurnStreamCollector

fn clone(&self) -> TurnStreamCollector

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for TurnStreamCollector

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

Formats the value using the given formatter.