Snodo.Transport.StreamableHTTP.StreamResponse (snodo v0.2.0)

Copy Markdown View Source

A transport-server-agnostic long-lived SSE response descriptor.

Embedding HTTP stacks write the headers and acknowledgement, then use the contained Snodo.Subscription lifecycle API to pull and shape events.

Summary

Types

headers()
t()

Types

headers()

@type headers() :: [{String.t(), String.t()}]

t()

@type t() :: %Snodo.Transport.StreamableHTTP.StreamResponse{
  headers: headers(),
  keepalive_ms: pos_integer(),
  status: pos_integer(),
  subscription: Snodo.Subscription.t()
}