Struct CollectingStreamHandler 

pub struct CollectingStreamHandler { /* private fields */ }

Default streaming handler that collects chunks

Implementations

impl CollectingStreamHandler

pub fn new() -> Self

Create a new collecting handler

pub fn get_chunks(&self) -> Vec<StreamChunk>

Get collected chunks

pub fn get_complete_text(&self) -> String

Get complete text

Trait Implementations

impl Debug for CollectingStreamHandler

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

Formats the value using the given formatter.

impl Default for CollectingStreamHandler

fn default() -> CollectingStreamHandler

Returns the “default value” for a type.

impl StreamingHandler for CollectingStreamHandler

fn handle_chunk<'life0, 'async_trait>( &'life0 self, chunk: StreamChunk, ) -> Pin<Box<dyn Future<Output = LLMResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle a stream chunk

fn handle_completion<'life0, 'async_trait>( &'life0 self, _final_message: LLMMessage, _usage: TokenUsage, ) -> Pin<Box<dyn Future<Output = LLMResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle stream completion

fn handle_error<'life0, 'async_trait>( &'life0 self, _error: LLMError, ) -> Pin<Box<dyn Future<Output = LLMResult<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Handle stream error