Skip to main content

Module stream_adapter

Module stream_adapter 

Source
Expand description

Runtime SSE adaptation for cross-protocol content-generation streams.

Structs§

BufferedAggregation
BufferedDiagnostics
ResponsesStreamNormalizer
Stateful normalizer for an upstream that already speaks Responses SSE. Frames outside the currently modeled typed schema are forwarded unchanged.
SseTransformer
StreamDiagnostics
StreamOptions

Enums§

StreamErrorMode

Functions§

aggregate_buffered
Collapse a provider SSE stream into one response JSON of the same wire kind.
convert_buffered
Convert a fully-buffered SSE body.
synthesize_sse
Turn one complete response into the smallest useful SSE event sequence.