sse

Documentation

Overview

See https://html.spec.whatwg.org/multipage/server-sent-events.html

Index

• Constants
• Variables
• func ParseStream(r io.ReadCloser, maxSize int, f func(id, event string, data []byte) error, ...) error
• func VerifyResponse(resp *http.Response) error
• type Msg
  • func (msg *Msg) Encode(buf []byte) []byte
  • func (msg *Msg) EncodedLen() int
  • func (msg *Msg) String() string

Constants

const (
	ContentType = "text/event-stream"
)

Variables

var (
	ErrHTTPStatusNon200   = errors.New("HTTP status code indicates failure")
	ErrInvalidContentType = errors.New("invalid Content-Type, expected text/event-stream")

	// ErrCloseEventStream is a marker error that can be returned by
	// stream handling func to indicate that the event stream should be
	// closed.
	ErrCloseEventStream = errors.New("close event stream")
)

Functions

func ParseStream

func ParseStream(r io.ReadCloser, maxSize int, f func(id, event string, data []byte) error, retryf func(ms uint64)) error

func VerifyResponse

func VerifyResponse(resp *http.Response) error

Types

type Msg

type Msg struct {
	IDStr string
	ID    uint64
	Event string
	Data  []byte
}

func (*Msg) Encode

func (msg *Msg) Encode(buf []byte) []byte

func (*Msg) EncodedLen

func (msg *Msg) EncodedLen() int

func (*Msg) String

func (msg *Msg) String() string