Struct StreamingProcessor 

pub struct StreamingProcessor { /* private fields */ }

Streaming processor for handling real-time responses from the Gemini API

Implementations

impl StreamingProcessor

pub fn new() -> Self

Create a new streaming processor with default configuration

pub fn with_config(config: StreamingConfig) -> Self

Create a new streaming processor with custom configuration

pub async fn process_stream<F>( &mut self, response: Response, on_chunk: F, ) -> Result<StreamingResponse, StreamingError>

where F: FnMut(&str) -> Result<(), StreamingError>,

Process a streaming response from the Gemini API

This method takes a response and processes it in real-time, calling the provided callback for each chunk of content received.

Arguments

• response - The HTTP response from the Gemini API
• on_chunk - A callback function that will be called for each text chunk received

Returns

A result containing the final accumulated response or a streaming error

pub fn metrics(&self) -> &StreamingMetrics

Get current streaming metrics

pub fn reset_metrics(&mut self)

Reset streaming metrics

Trait Implementations

impl Default for StreamingProcessor

fn default() -> Self

Returns the “default value” for a type.