AgentSea. Providers. SSE
(agentsea_providers v0.1.0)
Copy Markdown
Frames a stream of raw HTTP body chunks into Server-Sent Events.
Pure and lazy: it buffers across chunk boundaries (an event may be split mid-
way between two network reads) and emits one map per complete event with its
:event name (if any) and concatenated :data payload.
Summary
Types
Functions
@spec events(Enumerable.t()) :: Enumerable.t()
Turn an enumerable of binary chunks into a lazy stream of event/0.