Struct ChunkNormalizer 

pub struct ChunkNormalizer { /* private fields */ }

Expands chunk events into the explicit events the rest of the protocol is written in.

Feed every event of a run through it, in order, and apply what comes out. Events that are not chunks pass through untouched — but they are still observed, so that an explicitly opened message can absorb a following bare chunk, and so an explicit end is not duplicated.

Implementations

impl ChunkNormalizer

pub fn new() -> Self

A normalizer with nothing open.

pub fn is_open(&self) -> bool

Whether any stream is currently open.

pub fn normalize(&mut self, event: Event, out: &mut Vec<Event>) -> Result<()>

Expands one event, appending the result to out.

Appends between zero and three events: the synthesized end of the previous stream, the synthesized start of this one, and the content.

Errors

A chunk that names no stream and has none to continue — none open, or several subagents’ open and no attribution to pick one — or a tool call chunk that opens a call without naming the tool, is a protocol violation: there is no id to attach the payload to, and guessing one would put text in the wrong message.

pub fn finish(&mut self, out: &mut Vec<Event>)

Closes whatever the normalizer opened but never got to end.

Call this when the transport stream ends. A chunk stream that never terminates is the normal case, not an error: the last message of a run has nothing after it to imply its end.

Trait Implementations

impl Clone for ChunkNormalizer

fn clone(&self) -> ChunkNormalizer

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChunkNormalizer

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

Formats the value using the given formatter.

impl Default for ChunkNormalizer

fn default() -> ChunkNormalizer

Returns the “default value” for a type.