View Source Anthropic.HTTPTransport.SSE (anthropic_community v0.5.0)

Minimal line-buffering Server-Sent-Events parser. Consumes raw byte chunks (as delivered by Finch.stream/5's :data callback) and emits complete {event_name, data} frames, buffering partial lines and partial frames across chunk boundaries.

Summary

Types

frame()
t()

Functions

feed(parser, chunk)

Feeds a raw byte chunk in; returns the complete frames it produced and the updated parser state.

new()

Types

Link to this type

frame()

View Source 
@type frame() :: {event :: String.t() | nil, data :: String.t()}
Link to this type

t()

View Source 
@type t() :: %Anthropic.HTTPTransport.SSE{
  buffer: String.t(),
  pending_data: [String.t()],
  pending_event: String.t() | nil
}

Functions

Link to this function

feed(parser, chunk)

View Source 
@spec feed(t(), binary()) :: {[frame()], t()}

Feeds a raw byte chunk in; returns the complete frames it produced and the updated parser state.

Link to this function

new()

View Source 
@spec new() :: t()