Struct StreamBuffer 

pub struct StreamBuffer { /* private fields */ }

Buffer that accumulates streaming tokens and decides when to flush.

Implementations

impl StreamBuffer

pub fn new(config: StreamConfig) -> Self

Create a new stream buffer.

pub fn push(&mut self, text: &str)

Add a text chunk to the buffer.

pub fn finish(&mut self)

Mark the stream as complete.

pub fn should_flush(&self) -> bool

Check if a flush is needed based on strategy and timing.

pub fn flush(&mut self) -> Option<FlushAction>

Get the current content to send/edit.

For EditInPlace: returns full accumulated content with cursor. For Chunked: returns the pending chunk and clears the buffer.

pub fn is_done(&self) -> bool

Check if streaming is complete.

pub fn content_len(&self) -> usize

Get current content length.

pub fn needs_split(&self) -> bool

Check if content exceeds max message length and needs splitting.

pub fn split_content(&self) -> Vec<String>

Split content into message-sized chunks.