Struct GenerationWsTurn 

pub struct GenerationWsTurn<'a, B: StreamBridge<NativeEvent = StreamEvent>> { /* private fields */ }

Owns the native turn while borrowing its caller-owned conversion progress. Dropping a nonterminal native turn poisons the connection; it never resends.

Implementations

impl GenerationWsTurn<'_, ResponsesToGeminiStream>

pub async fn next_with_image_resources<S, R>( &mut self, 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,

Perform actual URI publications while retaining the native WS turn and pending client events across cancellation of this individual future.

impl<B: StreamBridge<NativeEvent = StreamEvent>> GenerationWsTurn<'_, B>

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

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

pub fn invocation(&self) -> &StreamInvocation<B>

pub fn failure_event(&self) -> Option<&StreamEvent>

pub fn websocket_failure(&self) -> Option<&ErrorMessage>