Skip to main content

stream_gemini_request

synaps_cli::runtime::google_gemini::stream

Function stream_gemini_request 

Source 
pub async fn stream_gemini_request<B>(
    broker: &B,
    request: ProxyRequest,
    cancel: CancellationToken,
) -> Result<Pin<Box<dyn Stream<Item = Result<GeminiStreamEvent, StreamError>> + Send>>, StreamError>
where
    B: CredentialBroker + ?Sized,
Expand description

Start one broker stream attempt from a prebuilt request (see build_stream_request). Retry loops reuse the same request value per attempt so every attempt sends identical bytes.