Trait PartialStreamStore 

pub trait PartialStreamStore: Send + Sync {
    // Required method
    fn get_partial_stream<'life0, 'life1, 'async_trait>(
        &'life0 self,
        session_id: SessionId,
        turn_id: &'life1 str,
    ) -> Pin<Box<dyn Future<Output = Result<Option<PartialStreamState>>> + Send + 'async_trait>>
       where Self: 'async_trait,
             'life0: 'async_trait,
             'life1: 'async_trait;
}

Consults the persisted event log to detect whether a reason activity was interrupted after output.message.started but before output.message.completed or output.message.replaced.

Used by ReasonAtom on re-entry to apply the ContinuePartial recovery policy (EVE-532): finalize the partial text without a second provider call, or restart clean if the partial is unusable.

Required Methods

fn get_partial_stream<'life0, 'life1, 'async_trait>( &'life0 self, session_id: SessionId, turn_id: &'life1 str, ) -> Pin<Box<dyn Future<Output = Result<Option<PartialStreamState>>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Return the partial-stream state for (session_id, turn_id) if an in-flight assistant message exists (started but not completed).

Dyn Compatibility

This trait is dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl PartialStreamStore for NoopPartialStreamStore