Struct StreamingResponseHandler 

pub struct StreamingResponseHandler<'a> { /* private fields */ }

Handler for streaming SSE response conversion. Processes Chat API SSE chunks and converts them to Responses API SSE events.

Implementations

impl<'a> StreamingResponseHandler<'a>

pub fn new( ctx: &'a mut ProxyContext, provider: Option<Arc<dyn Provider>>, log_body: bool, conversation_store: Arc<ConversationStore>, ) -> Self

Create a new streaming handler.

pub fn process_stream_frame(&mut self) -> Option<String>

Process a single streaming frame/body chunk.

Parses SSE events from the accumulated response body (starting from last parsed offset), converts each ChatStreamChunk to Responses API events, and returns the combined SSE output.

Returns None if no conversion events were generated.

pub fn finalize_stream(&mut self) -> Vec<String>

Finalize the stream by appending response.completed event.

Should be called at end_of_body when streaming conversion is enabled. Returns SSE events for the completed response, including [DONE] marker.