Struct StepAssembler 

pub struct StepAssembler { /* private fields */ }

Available on crate feature async-client only.

Accumulates StepUpdate frames into Steps.

Implementations

impl StepAssembler

pub fn new(main_trajectory: Option<String>) -> Self

A fresh assembler for a conversation.

main_trajectory should be the conversation’s cascade id when known; otherwise the first trajectory seen is adopted as the main one.

pub fn main_trajectory(&self) -> Option<&str>

The trajectory treated as the main conversation.

pub fn is_main(&self, trajectory_id: &str) -> bool

True when trajectory_id is the main conversation rather than a subagent’s.

pub fn ingest(&mut self, update: StepUpdate) -> Step

Folds one update into the running state and returns the merged step.

Trait Implementations

impl Debug for StepAssembler

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

Formats the value using the given formatter.

impl Default for StepAssembler

fn default() -> StepAssembler

Returns the “default value” for a type.