Backplane.AiProtocol.Antigravity.Stream (backplane_ai_protocol v1.10.36)

Copy Markdown

Bounded native SSE document decoder for Antigravity streaming responses.

Summary

Types

t()

Functions

feed(state, chunk)
finish(state, arg2)
new(opts \\ [])

Types

t()

@type t() :: %Backplane.AiProtocol.Antigravity.Stream{
  bytes_seen: term(),
  events_seen: term(),
  max_events: term(),
  max_total_bytes: term(),
  protocol_terminal: term(),
  sse: term(),
  terminal: term()
}

Functions

feed(state, chunk)

@spec feed(t(), term()) ::
  {:ok, t(), [map()]} | {:error, Backplane.AiProtocol.Error.t(), t()}

finish(state, arg2)

@spec finish(t(), atom()) ::
  {:ok, t(), [map()]} | {:error, Backplane.AiProtocol.Error.t(), t()}

new(opts \\ [])

@spec new(keyword()) :: t()