Tinkex.Streaming.SSEDecoder (Tinkex v0.3.4)

Minimal SSE decoder that can be fed incremental chunks.

Summary

t()

Feed a binary chunk into the decoder, returning parsed events and updated state.

new()

Create a new decoder.

@type t() :: %Tinkex.Streaming.SSEDecoder{buffer: binary()}

@spec feed(t(), binary()) :: {[Tinkex.Streaming.ServerSentEvent.t()], t()}

Feed a binary chunk into the decoder, returning parsed events and updated state.

@spec new() :: t()

Create a new decoder.