Struct StreamAggregator 

pub struct StreamAggregator { /* private fields */ }

Concurrent, lock-free streaming response aggregator.

channel_capacity controls the bounded broadcast channel depth. Lagging subscribers that cannot keep up will have their oldest messages dropped.

Implementations

impl StreamAggregator

pub fn new(channel_capacity: usize) -> Self

Create a new aggregator with the given per-session broadcast capacity.

pub fn feed(&self, chunk: StreamChunk)

Feed a token chunk into the aggregator.

Internally:

• A per-session buffer is created on first access.
• The token is appended to the buffer.
• The chunk is broadcast to any active subscribers.

pub fn complete(&self, session_id: u64) -> Option<String>

Flush the session buffer and return the complete assembled text.

Returns None if the session has never received any chunks. After calling complete, the session entry is removed from the map.

pub fn subscribe( &self, session_id: u64, ) -> Pin<Box<dyn Stream<Item = StreamChunk> + Send + 'static>>

Subscribe to real-time token chunks for a session.

Returns a [Stream] that yields every StreamChunk fed for session_id after the subscription is registered. Chunks that arrived before the call are not replayed.

If the session does not yet exist, an empty buffer entry is created so that future feed calls reach the subscriber.

pub fn stats(&self) -> AggStats

Return aggregate statistics.

Trait Implementations

impl Clone for StreamAggregator

fn clone(&self) -> StreamAggregator

Returns a duplicate of the value.

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

Performs copy-assignment from source.