Struct OutputHub 

pub struct OutputHub { /* private fields */ }

Bounded retained output with atomic snapshot-to-live subscription handoff.

Implementations

impl OutputHub

pub fn new(call_id: ToolCallId, retention_bytes: usize) -> Self

pub fn declare(&self, declaration: &ToolOutputDeclaration)

pub fn streams(&self) -> Vec<OutputStream>

pub fn emit(&self, stream: OutputStream, data: &[u8])

pub fn subscribe( &self, stream: OutputStream, queue: usize, ) -> (OutputSnapshot, Receiver<OutputMessage>)

Holds the same lock while taking the snapshot and registering the receiver, so subsequent deltas cannot fall into a handoff gap.

pub fn finalize(&self)

Prevents late producer clones from publishing after the owning call has been committed as complete and closes every live subscription.

Trait Implementations

impl Clone for OutputHub

fn clone(&self) -> OutputHub

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutputHub

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

Formats the value using the given formatter.