Struct FanoutStream 

pub struct FanoutStream<B: FanoutBridge>
where
    B::ClientEvent: FanoutEvent,
{ /* private fields */ }

Caller-owned progress retains every child receipt and the active stream across cancellation, in memory only. Dropping it cancels the active body.

Implementations

impl FanoutStream<ResponsesToGeminiStream>

pub async fn next_with_image_resources<U: Upstream, S, R>( &mut self, upstream: &U, target: &U::Target, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, progress: &mut [ImageStreamProgress<R::PublishedHandle>], ) -> Result<Option<StreamChunk<GenerateContentResponseBody>>, TransformError>

where R: ResourceAccess + ResourceSync, R::Scope: ResourceSync, R::PublishedHandle: ResourceSend, S: StateStore + ResourceSync, S::Scope: ResourceSync,

Keep one progress entry per child. Publication operation IDs and receipts survive cancellation, and resource budgets apply to the whole group.

pub async fn collect_with_image_resources<U: Upstream, S, R>( &mut self, upstream: &U, target: &U::Target, state: &GenerationStateAccess<'_, S>, resources: &GenerationResources<'_, R>, progress: &mut [ImageStreamProgress<R::PublishedHandle>], ) -> Result<Converted<GenerateContentResponseBody>, TransformError>

where R: ResourceAccess + ResourceSync, R::Scope: ResourceSync, R::PublishedHandle: ResourceSend, S: StateStore + ResourceSync, S::Scope: ResourceSync,

impl<B: FanoutBridge> FanoutStream<B>

where B::ClientEvent: FanoutEvent,

pub async fn next<U: Upstream, S: StateStore>( &mut self, upstream: &U, target: &U::Target, state: &GenerationStateAccess<'_, S>, ) -> Result<Option<StreamChunk<B::ClientEvent>>, TransformError>

Starts each unstarted child once and returns incremental client bytes. Errors retain native receipts in memory; cancellation during a POST never triggers a second POST.

pub async fn collect<U: Upstream, S: StateStore>( &mut self, upstream: &U, target: &U::Target, state: &GenerationStateAccess<'_, S>, ) -> Result<Converted<<<B as StreamBridge>::ClientEvent as NativeEvent>::Full>, TransformError>

impl<B: FanoutBridge> FanoutStream<B>

where B::ClientEvent: FanoutEvent,

pub fn children(&self) -> &[StreamInvocation<B>]

pub fn response_id(&self) -> &str

pub fn report(&self) -> &Report

pub fn client_result( &self, ) -> Option<&<<B as StreamBridge>::ClientEvent as NativeEvent>::Full>