Struct GeminiStreamCollector 

pub struct GeminiStreamCollector { /* private fields */ }

Collects native chunks without retaining a second copy of the event log. Content is incremental; usage and non-content metadata are native cumulative snapshots. A failed push poisons the collector so partial state cannot pass.

Implementations

impl GeminiStreamCollector

pub fn new(limits: GeminiStreamLimits) -> Self

pub fn push( &mut self, chunk: GenerateContentResponseBody, ) -> Result<(), TransformError>

pub fn finish( self, ) -> Result<Converted<GenerateContentResponseBody>, TransformError>

EOF is successful only once every observed candidate has a terminal reason, or the prompt was explicitly blocked before creating candidates.