LLMProxy.Stream.Event (llm_proxy v0.2.0)

Server-sent stream event with protocol wire-event constructors.

Summary

kind()

t()

@type kind() ::
  :start
  | :content
  | :reasoning
  | :tool_call
  | :usage
  | :finish
  | :error
  | :metadata

@type t() :: %LLMProxy.Stream.Event{
  data: map() | String.t(),
  event: String.t() | nil,
  kind: kind(),
  usage: LLMProxy.Usage.t() | nil
}

@spec attach_usage(t(), LLMProxy.Usage.t() | nil) :: t()

@spec from_openai_map(map()) :: t()

@spec from_openai_sse(%{optional(:data) => term()}) :: t() | nil

@spec new(
  map() | String.t(),
  keyword()
) :: t()

@spec openai_chat_content_delta(String.t(), String.t()) :: t()

@spec openai_chat_delta(String.t(), map(), atom() | nil, map() | nil) :: t()

@spec openai_chat_terminal(String.t(), atom() | nil, map() | nil) :: t()

@spec openai_chat_tool_call_arguments_delta(non_neg_integer(), String.t(), String.t()) ::
  t()

@spec openai_chat_tool_call_delta(
  non_neg_integer(),
  String.t(),
  String.t(),
  map(),
  String.t()
) :: t()

@spec output_delta?(t()) :: boolean()

@spec responses_function_call_added(non_neg_integer(), String.t(), String.t(), map()) ::
  t()

@spec responses_output_text_delta(String.t()) :: t()

@spec responses_reasoning_delta(String.t()) :: t()

@spec responses_terminal(atom() | nil, String.t(), map()) :: t()