gproxy-protocol 4.1.2

GPROXY v4 connection modelling, operation declarations, vendor wire types and pairwise conversion
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use super::{GeminiStreamCollector, GeminiStreamLimits};
use crate::{
    transform::{Converted, TransformError},
    wire::{DeclaredFields, gemini as g},
};

/// Gemini streams contain the same native response body as buffered delivery.
/// A single terminal chunk is a valid synthesized stream. Validation shares the
/// collector's complete lifecycle and memory bounds; no counters are invented.
pub fn synthesize_gemini_stream(
    input: g::GenerateContentResponseBody,
    limits: GeminiStreamLimits,
) -> Result<Converted<Vec<g::GenerateContentResponseBody>>, TransformError> {
    let input = input.into_declared();
    let mut collector = GeminiStreamCollector::new(limits);
    collector.push(input)?;
    let validated = collector.finish()?;
    Ok(Converted {
        value: vec![validated.value],
        report: validated.report,
    })
}