Struct StreamState 

pub struct StreamState {
    pub response_id: String,
    pub output_id: String,
    pub model: String,
    pub text: TextAccumulator,
    pub indices: IndexAllocator,
    pub usage: UsageMetrics,
    pub tool_calls: ToolCallTracker,
    pub emit: EmitState,
    pub request_context: Option<ResponseRequestContext>,
}

Streaming converter state for tracking incremental changes.

Fields

response_id: String

output_id: String

model: String

text: TextAccumulator

indices: IndexAllocator

usage: UsageMetrics

tool_calls: ToolCallTracker

emit: EmitState

request_context: Option<ResponseRequestContext>

Backwards-compat carrier for the request context. New code paths should pass Option<&ResponseRequestContext> directly to build_response_object; this field will be removed once ProxyContext stores the context separately.

Implementations

impl StreamState

pub fn new( response_id: String, model: String, request_context: Option<ResponseRequestContext>, ) -> Self

Create a new stream state.

pub fn take_sequence_number(&mut self) -> u64

Allocate and return the next sequence number, then advance the counter.

pub fn update_usage(&mut self, chunk: &ChatStreamChunk)

Update usage from a ChatStreamChunk.

pub fn build_response_object(&self) -> Box<ResponseObject>

Build the final ResponseObject with all accumulated outputs.

The ctx parameter supplies request-level fields (instructions, tools, sampling params, etc.). It defaults to self.request_context for backwards compatibility but new callers should pass it explicitly.

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

Formats the value using the given formatter.