Struct CollectSink 

pub struct CollectSink(pub Arc<Mutex<String>>);

A sink that accumulates everything it is given into a shared buffer.

Used by the parallel fan-out: the sub-agent pane holds one label and one log, so N concurrent sidechains streaming live would interleave into unreadable output. Each slot collects here instead and is flushed as one labelled block when it finishes.

Tuple Fields

0: Arc<Mutex<String>>

Implementations

impl CollectSink

pub fn take(&self) -> String

Takes the collected text, leaving the buffer empty.

Trait Implementations

impl Clone for CollectSink

fn clone(&self) -> CollectSink

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for CollectSink

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

Formats the value using the given formatter.

impl Default for CollectSink

fn default() -> CollectSink

Returns the “default value” for a type.

impl RenderSink for CollectSink

fn visible_text(&mut self, text: &str)

Receives ordinary visible output.

fn think_text(&mut self, _text: &str)

Receives text produced inside a <think> block.

fn tool_text(&mut self, text: &str)

Receives tool banner output (never markdown); defaults to visible.

fn error_text(&mut self, text: &str)

Receives error banners (e.g. [invalid tool call: ...]); sinks should style these red. Defaults to tool text.