Struct SseEncoder 

pub struct SseEncoder {
    pub id: String,
    pub model: String,
    pub created: u64,
}

Stateful encoder that produces OpenAI-shape SSE frames for one response.

The id, model, and created fields are stable across all frames the encoder produces, matching the OpenAI streaming contract.

Fields

id: String

Stable response id, e.g. "chatcmpl-…".

model: String

Model name as advertised to the client (NOT the upstream alias).

created: u64

Unix epoch seconds when the response was created.

Implementations

impl SseEncoder

pub fn new( id: impl Into<String>, model: impl Into<String>, created: u64, ) -> Self

Construct a new encoder with the stable response metadata.

pub fn encode(&self, event: &LlmStreamEvent) -> Option<String>

Encode a single LlmStreamEvent into one or more SSE frames.

Returns None when the event is not meant to appear on the wire (e.g. LlmStreamEvent::NormalizationError, which the proxy logs but never forwards to clients).

For LlmStreamEvent::Done, the returned String includes both the terminating chunk (with finish_reason set) and the trailing data: [DONE]\n\n sentinel, so the caller can write a single payload and end the response.

fn frame(&self, choice: &Value) -> String

Wrap a choice value in the standard chunk envelope and SSE framing.

Trait Implementations

impl Clone for SseEncoder

fn clone(&self) -> SseEncoder

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for SseEncoder

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

Formats the value using the given formatter.