Struct StreamState 

pub struct StreamState {
    pub status: StreamStatus,
    pub text: String,
    pub reasoning: String,
    pub error: Option<ModelError>,
    /* private fields */
}

Retained presentation state for one inference attempt. Deltas are inert; only response() exposes a validated, completed turn for dispatch. There is deliberately no automatic retry: callers keep committed conversation/results and start new inference rather than re-executing a previous action batch.

Fields

status: StreamStatus

text: String

reasoning: String

error: Option<ModelError>

Implementations

impl StreamState

pub fn apply(&mut self, event: &StreamEvent)

Terminal states are sticky, including cancellation racing a late finish.

pub fn fail(&mut self, error: ModelError)

Called on EOF, missing final frame or watchdog expiration. Partial prose and reasoning remain available, but no calls become executable.

pub fn cancel(&mut self)

pub fn response(&self) -> Option<&ModelResponse>

pub fn continue_text( &self, history: &Conversation, max_output_tokens: u32, ) -> Result<ModelRequest, ModelError>

Explicit prose-only continuation. Uses committed history plus retained answer text, never partial tool arguments or reasoning. Tools are disabled so continuation cannot replay an action. The original history is unchanged.

Errors

Rejects states without a truncated, nonempty prose answer.

Trait Implementations

impl Clone for StreamState

fn clone(&self) -> StreamState

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for StreamState

fn fmt(&self, f: &mut Formatter<'_>) -> Result<(), Error>

Formats the value using the given formatter.

impl Default for StreamState

fn default() -> StreamState

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for StreamState

fn deserialize<__D>( __deserializer: __D, ) -> Result<StreamState, <__D as Deserializer<'de>>::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl PartialEq for StreamState

fn eq(&self, other: &StreamState) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Serialize for StreamState

fn serialize<__S>( &self, __serializer: __S, ) -> Result<<__S as Serializer>::Ok, <__S as Serializer>::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl StructuralPartialEq for StreamState