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

Functions

Turn an enumerable of binary chunks into a lazy stream of event/0.

Types

event()

@type event() :: %{event: String.t() | nil, data: String.t()}

Functions

events(chunks)

@spec events(Enumerable.t()) :: Enumerable.t()

Turn an enumerable of binary chunks into a lazy stream of event/0.