Toolnexus.Mcp.Transport.Sse (toolnexus v0.9.4)

Copy Markdown View Source

Incremental server-sent-events parser: feed chunks, collect complete events. MCP-style streams (event:/data: lines, no [DONE] sentinel).

Summary

Functions

Feed a chunk; returns {events, state} where each event is %{event: name, data: string}.

Parse a complete buffered SSE body (lenient: flushes a trailing unterminated event).

Functions

feed(s, chunk)

Feed a chunk; returns {events, state} where each event is %{event: name, data: string}.

new()

parse_all(binary)

Parse a complete buffered SSE body (lenient: flushes a trailing unterminated event).