sse

import "github.com/grx-gql/grx/sse"

IndexCopy Anchor Link

• type Transport
  • func New() *Transport
  • func (Transport) Match(r *http.Request) bool
  • func (Transport) Serve(w http.ResponseWriter, r *http.Request, executor core.Executor)

type TransportCopy Anchor Link

Transport streams GraphQL subscription responses over Server-Sent Events. It is safe to share across requests.

type Transport struct{}

func NewCopy Anchor Link

func New() *Transport

New returns a Transport ready to be registered with the server.

func (Transport) MatchCopy Anchor Link

func (Transport) Match(r *http.Request) bool

Match reports whether r is asking for a text/event-stream response.

func (Transport) ServeCopy Anchor Link

func (Transport) Serve(w http.ResponseWriter, r *http.Request, executor core.Executor)

Serve runs the SSE response loop, forwarding each emitted Response as a "next" event and closing with a "complete" event when the stream ends.

Generated by gomarkdoc